Interface IPollableSource<H>
An abstraction which defines a mechanism to poll a consumer
Namespace: Steeltoe.Stream.Binder
Assembly: Steeltoe.Stream.Abstractions.dll
Syntax
public interface IPollableSource<in H> : IPollableSource
Type Parameters
Name | Description |
---|---|
H | the handler type |
Methods
| Edit this page View SourcePoll(H)
Poll the consumer
Declaration
bool Poll(H handler)
Parameters
Type | Name | Description |
---|---|---|
H | handler | the handler to process message |
Returns
Type | Description |
---|---|
System.Boolean | 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).
Declaration
bool Poll(H handler, Type type)
Parameters
Type | Name | Description |
---|---|---|
H | handler | the handler |
Type | type | the type of the payload |
Returns
Type | Description |
---|---|
System.Boolean | true if a message was handled |