X

Class AbstractPollableMessageSourceBinder

Inheritance
System.Object
AbstractBinder<IMessageChannel>
AbstractMessageChannelBinder
AbstractPollableMessageSourceBinder
RabbitMessageChannelBinder
Implements
IBinder<IMessageChannel>
IPollableConsumerBinder<IMessageHandler>
IBinder<IPollableSource<IMessageHandler>>
IServiceNameAware
IDisposable
Inherited Members
Namespace: Steeltoe.Stream.Binder
Assembly: Steeltoe.Stream.StreamBase.dll
Syntax
public abstract class AbstractPollableMessageSourceBinder : AbstractMessageChannelBinder, IBinder<IMessageChannel>, IPollableConsumerBinder<IMessageHandler>, IBinder<IPollableSource<IMessageHandler>>, IBinder, IPollableConsumerBinder

Constructors

| Edit this page View Source

AbstractPollableMessageSourceBinder(IApplicationContext, String[], IProvisioningProvider, ILogger)

Declaration
protected AbstractPollableMessageSourceBinder(IApplicationContext context, string[] headersToEmbed, IProvisioningProvider provisioningProvider, ILogger logger)
Parameters
Type Name Description
IApplicationContext context
System.String[] headersToEmbed
IProvisioningProvider provisioningProvider
ILogger logger
| Edit this page View Source

AbstractPollableMessageSourceBinder(IApplicationContext, String[], IProvisioningProvider, IListenerContainerCustomizer, IMessageSourceCustomizer, ILogger)

Declaration
protected AbstractPollableMessageSourceBinder(IApplicationContext context, string[] headersToEmbed, IProvisioningProvider provisioningProvider, IListenerContainerCustomizer containerCustomizer, IMessageSourceCustomizer sourceCustomizer, ILogger logger)
Parameters
Type Name Description
IApplicationContext context
System.String[] headersToEmbed
IProvisioningProvider provisioningProvider
IListenerContainerCustomizer containerCustomizer
IMessageSourceCustomizer sourceCustomizer
ILogger logger

Methods

| Edit this page View Source

BindConsumer(String, String, IPollableSource<IMessageHandler>, IConsumerOptions)

Declaration
public virtual IBinding BindConsumer(string name, string group, IPollableSource<IMessageHandler> inboundTarget, IConsumerOptions consumerOptions)
Parameters
Type Name Description
System.String name
System.String group
IPollableSource<IMessageHandler> inboundTarget
IConsumerOptions consumerOptions
Returns
Type Description
IBinding
| Edit this page View Source

BindConsumer(String, String, Object, IConsumerOptions)

Declaration
public override IBinding BindConsumer(string name, string group, object inboundTarget, IConsumerOptions consumerOptions)
Parameters
Type Name Description
System.String name
System.String group
System.Object inboundTarget
IConsumerOptions consumerOptions
Returns
Type Description
IBinding
Overrides
Steeltoe.Stream.Binder.AbstractBinder<IMessageChannel>.BindConsumer(System.String, System.String, System.Object, Steeltoe.Stream.Config.IConsumerOptions)
| Edit this page View Source

BindProducer(String, IPollableSource<IMessageHandler>, IProducerOptions)

Declaration
public virtual IBinding BindProducer(string name, IPollableSource<IMessageHandler> outboundTarget, IProducerOptions producerOptions)
Parameters
Type Name Description
System.String name
IPollableSource<IMessageHandler> outboundTarget
IProducerOptions producerOptions
Returns
Type Description
IBinding
| Edit this page View Source

CreatePolledConsumerResources(String, String, IConsumerDestination, IConsumerOptions)

Declaration
protected virtual AbstractMessageChannelBinder.PolledConsumerResources CreatePolledConsumerResources(string name, string group, IConsumerDestination destination, IConsumerOptions consumerOptions)
Parameters
Type Name Description
System.String name
System.String group
IConsumerDestination destination
IConsumerOptions consumerOptions
Returns
Type Description
AbstractMessageChannelBinder.PolledConsumerResources
| Edit this page View Source

GetPolledConsumerRecoveryCallback(AbstractMessageChannelBinder.ErrorInfrastructure, IConsumerOptions)

Declaration
protected virtual IRecoveryCallback GetPolledConsumerRecoveryCallback(AbstractMessageChannelBinder.ErrorInfrastructure errorInfrastructure, IConsumerOptions options)
Parameters
Type Name Description
AbstractMessageChannelBinder.ErrorInfrastructure errorInfrastructure
IConsumerOptions options
Returns
Type Description
IRecoveryCallback
| Edit this page View Source

PostProcessPollableSource(DefaultPollableMessageSource)

Declaration
protected virtual void PostProcessPollableSource(DefaultPollableMessageSource bindingTarget)
Parameters
Type Name Description
DefaultPollableMessageSource bindingTarget

Implements

IServiceNameAware
IDisposable