Class AbstractPollableMessageSourceBinder

Namespace

Steeltoe.Stream.Binder

Assembly

Steeltoe.Stream.StreamBase.dll

public abstract class AbstractPollableMessageSourceBinder : AbstractMessageChannelBinder, IBinder<IMessageChannel>, IPollableConsumerBinder<IMessageHandler>, IBinder<IPollableSource<IMessageHandler>>, IBinder, IServiceNameAware, IDisposable, IPollableConsumerBinder

Inheritance

object

AbstractBinder<IMessageChannel>

AbstractMessageChannelBinder

AbstractPollableMessageSourceBinder

Implements

IBinder<IMessageChannel>

IPollableConsumerBinder<IMessageHandler>

IBinder<IPollableSource<IMessageHandler>>

IBinder

IServiceNameAware

IDisposable

IPollableConsumerBinder

Derived

RabbitMessageChannelBinder

Inherited Members

AbstractMessageChannelBinder._provisioningProvider

AbstractMessageChannelBinder._embeddedHeadersChannelInterceptor

AbstractMessageChannelBinder._headersToEmbed

AbstractMessageChannelBinder._producerBindingExist

AbstractMessageChannelBinder.TargetType

AbstractMessageChannelBinder.ListenerContainerCustomizer

AbstractMessageChannelBinder.MessageSourceCustomizer

AbstractMessageChannelBinder.DoBindProducer(string, IMessageChannel, IProducerOptions)

AbstractMessageChannelBinder.UseNativeEncoding(IProducerOptions)

AbstractMessageChannelBinder.PostProcessOutputChannel(IMessageChannel, IProducerOptions)

AbstractMessageChannelBinder.CreateProducerMessageHandler(IProducerDestination, IProducerOptions, IMessageChannel, IMessageChannel)

AbstractMessageChannelBinder.CreateProducerMessageHandler(IProducerDestination, IProducerOptions, IMessageChannel)

AbstractMessageChannelBinder.AfterUnbindProducer(IProducerDestination, IProducerOptions)

AbstractMessageChannelBinder.DoBindConsumer(string, string, IMessageChannel, IConsumerOptions)

AbstractMessageChannelBinder.CreateConsumerEndpoint(IConsumerDestination, string, IConsumerOptions)

AbstractMessageChannelBinder.AfterUnbindConsumer(IConsumerDestination, string, IConsumerOptions)

AbstractMessageChannelBinder.RegisterErrorInfrastructure(IConsumerDestination, string, IConsumerOptions, ILogger)

AbstractMessageChannelBinder.RegisterErrorInfrastructure(IConsumerDestination, string, IConsumerOptions, bool, ILogger)

AbstractMessageChannelBinder.GetErrorMessageHandler(IConsumerDestination, string, IConsumerOptions)

AbstractMessageChannelBinder.GetPolledConsumerErrorMessageHandler(IConsumerDestination, string, IConsumerOptions)

AbstractMessageChannelBinder.GetDefaultErrorMessageHandler(ILastSubscriberAwareChannel, bool)

AbstractMessageChannelBinder.GetErrorMessageStrategy()

AbstractMessageChannelBinder.GetErrorRecovererName(IConsumerDestination, string, IConsumerOptions)

AbstractMessageChannelBinder.GetErrorMessageHandlerName(IConsumerDestination, string, IConsumerOptions)

AbstractMessageChannelBinder.GetErrorsBaseName(IProducerDestination)

AbstractMessageChannelBinder.GetErrorsBaseName(IConsumerDestination, string, IConsumerOptions)

AbstractMessageChannelBinder.GetErrorBridgeName(IConsumerDestination, string, IConsumerOptions)

AbstractMessageChannelBinder.GetErrorBridgeName(IProducerDestination)

AbstractBinder<IMessageChannel>.ApplicationContext

AbstractBinder<IMessageChannel>.ApplyPrefix(string, string)

AbstractBinder<IMessageChannel>.ConstructDLQName(string)

AbstractBinder<IMessageChannel>.ServiceName

AbstractBinder<IMessageChannel>.BindConsumer(string, string, IMessageChannel, IConsumerOptions)

AbstractBinder<IMessageChannel>.BindProducer(string, IMessageChannel, IProducerOptions)

AbstractBinder<IMessageChannel>.BindProducer(string, object, IProducerOptions)

AbstractBinder<IMessageChannel>.Dispose()

AbstractBinder<IMessageChannel>.EvaluationContext

AbstractBinder<IMessageChannel>.ExpressionParser

AbstractBinder<IMessageChannel>.GroupedName(string, string)

AbstractBinder<IMessageChannel>.BuildRetryTemplate(IConsumerOptions)

AbstractBinder<IMessageChannel>.GetRetryableExceptions(List<string>)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

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

protected AbstractPollableMessageSourceBinder(IApplicationContext context, string[] headersToEmbed, IProvisioningProvider provisioningProvider, ILogger logger)

Parameters

context IApplicationContext

headersToEmbed string[]

provisioningProvider IProvisioningProvider

logger ILogger

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

protected AbstractPollableMessageSourceBinder(IApplicationContext context, string[] headersToEmbed, IProvisioningProvider provisioningProvider, IListenerContainerCustomizer containerCustomizer, IMessageSourceCustomizer sourceCustomizer, ILogger logger)

Parameters

context IApplicationContext

headersToEmbed string[]

provisioningProvider IProvisioningProvider

containerCustomizer IListenerContainerCustomizer

sourceCustomizer IMessageSourceCustomizer

logger ILogger

Methods

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

Bind the target component as a message consumer to the logical entity identified by the name.

public virtual IBinding BindConsumer(string name, string group, IPollableSource<IMessageHandler> inboundTarget, IConsumerOptions consumerOptions)

Parameters

name string

the logical identity of the message source

group string

the consumer group to which this consumer belongs

inboundTarget IPollableSource<IMessageHandler>

the application interface to be bound as a consumer

consumerOptions IConsumerOptions

the consumer options

Returns

IBinding

the setup binding

BindConsumer(string, string, object, IConsumerOptions)

Bind the target component as a message consumer to the logical entity identified by the name.

public override IBinding BindConsumer(string name, string group, object inboundTarget, IConsumerOptions consumerOptions)

Parameters

name string

the logical identity of the message source

group string

the consumer group to which this consumer belongs

inboundTarget object

the application interface to be bound as a consumer

consumerOptions IConsumerOptions

the consumer options

Returns

IBinding

the setup binding

BindProducer(string, IPollableSource<IMessageHandler>, IProducerOptions)

Bind the target component as a message producer to the logical entity identified by the name.

public virtual IBinding BindProducer(string name, IPollableSource<IMessageHandler> outboundTarget, IProducerOptions producerOptions)

Parameters

name string

the logical identity of the message outbound target

outboundTarget IPollableSource<IMessageHandler>

the application interface to be bound as a producer

producerOptions IProducerOptions

the producer options

Returns

IBinding

the setup binding

CreatePolledConsumerResources(string, string, IConsumerDestination, IConsumerOptions)

protected virtual AbstractMessageChannelBinder.PolledConsumerResources CreatePolledConsumerResources(string name, string group, IConsumerDestination destination, IConsumerOptions consumerOptions)

Parameters

name string

group string

destination IConsumerDestination

consumerOptions IConsumerOptions

Returns

AbstractMessageChannelBinder.PolledConsumerResources

GetPolledConsumerRecoveryCallback(ErrorInfrastructure, IConsumerOptions)

protected virtual IRecoveryCallback GetPolledConsumerRecoveryCallback(AbstractMessageChannelBinder.ErrorInfrastructure errorInfrastructure, IConsumerOptions options)

Parameters

errorInfrastructure AbstractMessageChannelBinder.ErrorInfrastructure

options IConsumerOptions

Returns

IRecoveryCallback

PostProcessPollableSource(DefaultPollableMessageSource)

protected virtual void PostProcessPollableSource(DefaultPollableMessageSource bindingTarget)

Parameters

bindingTarget DefaultPollableMessageSource