Interface IPollableSource<H>

Namespace

Steeltoe.Stream.Binder

Assembly

Steeltoe.Stream.Abstractions.dll

An abstraction which defines a mechanism to poll a consumer

public interface IPollableSource<in H> : IPollableSource

Type Parameters

H

the handler type

Inherited Members

IPollableSource.Poll(object)

IPollableSource.Poll(object, Type)

Methods

Poll(H)

Poll the consumer

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).

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