Class AbstractPollableSource<H>

Namespace

Steeltoe.Stream.Binder

Assembly

Steeltoe.Stream.StreamBase.dll

public abstract class AbstractPollableSource<H> : IPollableSource<H>, IPollableSource

Type Parameters

H

Inheritance

object

AbstractPollableSource<H>

Implements

IPollableSource<H>

IPollableSource

Derived

DefaultPollableMessageSource

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

Poll(object)

Poll the consumer

public bool Poll(object handler)

Parameters

handler object

the handler to process message

Returns

bool

true if a message was handled

Poll(object, Type)

Poll the consumer and convert the payload to the specified type. Throw a RequeueCurrentMessageException to force the current message to be requeued in the broker(after retries are exhausted, if configured).

public bool Poll(object handler, Type type)

Parameters

handler object

the handler

type Type

the type of the payload

Returns

bool

true if a message was handled

Poll(H)

Poll the consumer

public abstract bool Poll(H handler)

Parameters

handler H

the handler to process message

Returns

bool

true if a message was handled

Poll(H, Type)

Poll the consumer and convert the payload to the specified type. Throw a RequeueCurrentMessageException to force the current message to be requeued in the broker(after retries are exhausted, if configured).

public virtual bool Poll(H handler, Type type)

Parameters

handler H

the handler

type Type

the type of the payload

Returns

bool

true if a message was handled