X

Class DefaultPollableMessageSource

Inheritance
System.Object
AbstractPollableSource<IMessageHandler>
DefaultPollableMessageSource
Implements
IPollableSource<IMessageHandler>
ILifecycle
IRetryListener
Inherited Members
Namespace: Steeltoe.Stream.Binder
Assembly: Steeltoe.Stream.StreamBase.dll
Syntax
public class DefaultPollableMessageSource : AbstractPollableSource<IMessageHandler>, IPollableSource<IMessageHandler>, IPollableMessageSource, IPollableSource<IMessageHandler>, IPollableSource

Constructors

| Edit this page View Source

DefaultPollableMessageSource(IApplicationContext, ISmartMessageConverter)

Declaration
public DefaultPollableMessageSource(IApplicationContext context, ISmartMessageConverter messageConverter)
Parameters
Type Name Description
IApplicationContext context
ISmartMessageConverter messageConverter

Properties

| Edit this page View Source

AttributeProvider

Declaration
public Action<IAttributeAccessor, IMessage> AttributeProvider { get; set; }
Property Value
Type Description
Action<IAttributeAccessor, IMessage>
| Edit this page View Source

ErrorChannel

Declaration
public IMessageChannel ErrorChannel { get; set; }
Property Value
Type Description
IMessageChannel
| Edit this page View Source

ErrorMessageStrategy

Declaration
public IErrorMessageStrategy ErrorMessageStrategy { get; set; }
Property Value
Type Description
IErrorMessageStrategy
| Edit this page View Source

IsRunning

Declaration
public bool IsRunning { get; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

RecoveryCallback

Declaration
public IRecoveryCallback RecoveryCallback { get; set; }
Property Value
Type Description
IRecoveryCallback
| Edit this page View Source

RetryTemplate

Declaration
public RetryTemplate RetryTemplate { get; set; }
Property Value
Type Description
RetryTemplate
| Edit this page View Source

Source

Declaration
public IMessageSource Source { get; set; }
Property Value
Type Description
IMessageSource

Methods

| Edit this page View Source

AddInterceptor(IChannelInterceptor)

Declaration
public void AddInterceptor(IChannelInterceptor interceptor)
Parameters
Type Name Description
IChannelInterceptor interceptor
| Edit this page View Source

AddInterceptor(Int32, IChannelInterceptor)

Declaration
public void AddInterceptor(int index, IChannelInterceptor interceptor)
Parameters
Type Name Description
System.Int32 index
IChannelInterceptor interceptor
| Edit this page View Source

Close(IRetryContext, Exception)

Declaration
public void Close(IRetryContext context, Exception exception)
Parameters
Type Name Description
IRetryContext context
Exception exception
| Edit this page View Source

OnError(IRetryContext, Exception)

Declaration
public void OnError(IRetryContext context, Exception exception)
Parameters
Type Name Description
IRetryContext context
Exception exception
| Edit this page View Source

Open(IRetryContext)

Declaration
public bool Open(IRetryContext context)
Parameters
Type Name Description
IRetryContext context
Returns
Type Description
System.Boolean
| Edit this page View Source

Poll(IMessageHandler)

Declaration
public override bool Poll(IMessageHandler handler)
Parameters
Type Name Description
IMessageHandler handler
Returns
Type Description
System.Boolean
Overrides
Steeltoe.Stream.Binder.AbstractPollableSource<IMessageHandler>.Poll(IMessageHandler)
| Edit this page View Source

Poll(IMessageHandler, Type)

Declaration
public override bool Poll(IMessageHandler handler, Type type)
Parameters
Type Name Description
IMessageHandler handler
Type type
Returns
Type Description
System.Boolean
Overrides
Steeltoe.Stream.Binder.AbstractPollableSource<IMessageHandler>.Poll(IMessageHandler, Type)
| Edit this page View Source

ShouldRequeue(Exception)

Declaration
protected static bool ShouldRequeue(Exception e)
Parameters
Type Name Description
Exception e
Returns
Type Description
System.Boolean
| Edit this page View Source

Start()

Declaration
public Task Start()
Returns
Type Description
Task
| Edit this page View Source

Stop()

Declaration
public Task Stop()
Returns
Type Description
Task

Implements

ILifecycle
IRetryListener