Class AbstractMessageChannelBinder

Namespace

Steeltoe.Stream.Binder

Assembly

Steeltoe.Stream.StreamBase.dll

public abstract class AbstractMessageChannelBinder : AbstractBinder<IMessageChannel>, IBinder<IMessageChannel>, IBinder, IServiceNameAware, IDisposable

Inheritance

object

AbstractBinder<IMessageChannel>

AbstractMessageChannelBinder

Implements

IBinder<IMessageChannel>

IBinder

IServiceNameAware

IDisposable

Derived

AbstractPollableMessageSourceBinder

Inherited Members

AbstractBinder<IMessageChannel>.ApplicationContext

AbstractBinder<IMessageChannel>.ApplyPrefix(string, string)

AbstractBinder<IMessageChannel>.ConstructDLQName(string)

AbstractBinder<IMessageChannel>.ServiceName

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

AbstractBinder<IMessageChannel>.BindConsumer(string, string, object, 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

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

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

Parameters

context IApplicationContext

headersToEmbed string[]

provisioningProvider IProvisioningProvider

logger ILogger

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

protected AbstractMessageChannelBinder(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

Fields

_embeddedHeadersChannelInterceptor

protected readonly AbstractMessageChannelBinder.EmbeddedHeadersChannelInterceptor _embeddedHeadersChannelInterceptor

Field Value

AbstractMessageChannelBinder.EmbeddedHeadersChannelInterceptor

_headersToEmbed

protected readonly string[] _headersToEmbed

Field Value

string[]

_producerBindingExist

protected bool _producerBindingExist

Field Value

bool

_provisioningProvider

protected readonly IProvisioningProvider _provisioningProvider

Field Value

IProvisioningProvider

Properties

ListenerContainerCustomizer

protected virtual IListenerContainerCustomizer ListenerContainerCustomizer { get; }

Property Value

IListenerContainerCustomizer

MessageSourceCustomizer

protected virtual IMessageSourceCustomizer MessageSourceCustomizer { get; }

Property Value

IMessageSourceCustomizer

TargetType

Gets the target type this binder can bind to

public override Type TargetType { get; }

Property Value

Type

Methods

AfterUnbindConsumer(IConsumerDestination, string, IConsumerOptions)

protected virtual void AfterUnbindConsumer(IConsumerDestination destination, string group, IConsumerOptions consumerOptions)

Parameters

destination IConsumerDestination

group string

consumerOptions IConsumerOptions

AfterUnbindProducer(IProducerDestination, IProducerOptions)

protected virtual void AfterUnbindProducer(IProducerDestination destination, IProducerOptions producerOptions)

Parameters

destination IProducerDestination

producerOptions IProducerOptions

CreateConsumerEndpoint(IConsumerDestination, string, IConsumerOptions)

protected abstract IMessageProducer CreateConsumerEndpoint(IConsumerDestination destination, string group, IConsumerOptions consumerOptions)

Parameters

destination IConsumerDestination

group string

consumerOptions IConsumerOptions

Returns

IMessageProducer

CreateProducerMessageHandler(IProducerDestination, IProducerOptions, IMessageChannel)

protected abstract IMessageHandler CreateProducerMessageHandler(IProducerDestination destination, IProducerOptions producerProperties, IMessageChannel errorChannel)

Parameters

destination IProducerDestination

producerProperties IProducerOptions

errorChannel IMessageChannel

Returns

IMessageHandler

CreateProducerMessageHandler(IProducerDestination, IProducerOptions, IMessageChannel, IMessageChannel)

protected virtual IMessageHandler CreateProducerMessageHandler(IProducerDestination destination, IProducerOptions producerProperties, IMessageChannel channel, IMessageChannel errorChannel)

Parameters

destination IProducerDestination

producerProperties IProducerOptions

channel IMessageChannel

errorChannel IMessageChannel

Returns

IMessageHandler

DoBindConsumer(string, string, IMessageChannel, IConsumerOptions)

protected override IBinding DoBindConsumer(string name, string group, IMessageChannel inputTarget, IConsumerOptions consumerOptions)

Parameters

name string

group string

inputTarget IMessageChannel

consumerOptions IConsumerOptions

Returns

IBinding

DoBindProducer(string, IMessageChannel, IProducerOptions)

protected override IBinding DoBindProducer(string name, IMessageChannel outboundTarget, IProducerOptions producerOptions)

Parameters

name string

outboundTarget IMessageChannel

producerOptions IProducerOptions

Returns

IBinding

GetDefaultErrorMessageHandler(ILastSubscriberAwareChannel, bool)

protected virtual IMessageHandler GetDefaultErrorMessageHandler(ILastSubscriberAwareChannel errorChannel, bool defaultErrorChannelPresent)

Parameters

errorChannel ILastSubscriberAwareChannel

defaultErrorChannelPresent bool

Returns

IMessageHandler

GetErrorBridgeName(IConsumerDestination, string, IConsumerOptions)

protected virtual string GetErrorBridgeName(IConsumerDestination destination, string group, IConsumerOptions consumerOptions)

Parameters

destination IConsumerDestination

group string

consumerOptions IConsumerOptions

Returns

string

GetErrorBridgeName(IProducerDestination)

protected virtual string GetErrorBridgeName(IProducerDestination destination)

Parameters

destination IProducerDestination

Returns

string

GetErrorMessageHandler(IConsumerDestination, string, IConsumerOptions)

protected virtual IMessageHandler GetErrorMessageHandler(IConsumerDestination destination, string group, IConsumerOptions consumerOptions)

Parameters

destination IConsumerDestination

group string

consumerOptions IConsumerOptions

Returns

IMessageHandler

GetErrorMessageHandlerName(IConsumerDestination, string, IConsumerOptions)

protected virtual string GetErrorMessageHandlerName(IConsumerDestination destination, string group, IConsumerOptions consumerOptions)

Parameters

destination IConsumerDestination

group string

consumerOptions IConsumerOptions

Returns

string

GetErrorMessageStrategy()

protected virtual IErrorMessageStrategy GetErrorMessageStrategy()

Returns

IErrorMessageStrategy

GetErrorRecovererName(IConsumerDestination, string, IConsumerOptions)

protected virtual string GetErrorRecovererName(IConsumerDestination destination, string group, IConsumerOptions consumerOptions)

Parameters

destination IConsumerDestination

group string

consumerOptions IConsumerOptions

Returns

string

GetErrorsBaseName(IConsumerDestination, string, IConsumerOptions)

protected virtual string GetErrorsBaseName(IConsumerDestination destination, string group, IConsumerOptions consumerOptions)

Parameters

destination IConsumerDestination

group string

consumerOptions IConsumerOptions

Returns

string

GetErrorsBaseName(IProducerDestination)

protected virtual string GetErrorsBaseName(IProducerDestination destination)

Parameters

destination IProducerDestination

Returns

string

GetPolledConsumerErrorMessageHandler(IConsumerDestination, string, IConsumerOptions)

protected virtual IMessageHandler GetPolledConsumerErrorMessageHandler(IConsumerDestination destination, string group, IConsumerOptions consumerProperties)

Parameters

destination IConsumerDestination

group string

consumerProperties IConsumerOptions

Returns

IMessageHandler

PostProcessOutputChannel(IMessageChannel, IProducerOptions)

protected virtual void PostProcessOutputChannel(IMessageChannel outputChannel, IProducerOptions producerOptions)

Parameters

outputChannel IMessageChannel

producerOptions IProducerOptions

RegisterErrorInfrastructure(IConsumerDestination, string, IConsumerOptions, ILogger)

protected virtual AbstractMessageChannelBinder.ErrorInfrastructure RegisterErrorInfrastructure(IConsumerDestination destination, string group, IConsumerOptions consumerOptions, ILogger logger)

Parameters

destination IConsumerDestination

group string

consumerOptions IConsumerOptions

logger ILogger

Returns

AbstractMessageChannelBinder.ErrorInfrastructure

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

protected virtual AbstractMessageChannelBinder.ErrorInfrastructure RegisterErrorInfrastructure(IConsumerDestination destination, string group, IConsumerOptions consumerOptions, bool polled, ILogger logger)

Parameters

destination IConsumerDestination

group string

consumerOptions IConsumerOptions

polled bool

logger ILogger

Returns

AbstractMessageChannelBinder.ErrorInfrastructure

UseNativeEncoding(IProducerOptions)

protected virtual bool UseNativeEncoding(IProducerOptions producerOptions)

Parameters

producerOptions IProducerOptions

Returns

bool