Class RabbitMessageChannelBinder

Namespace

Steeltoe.Stream.Binder.Rabbit

Assembly

Steeltoe.Stream.Binder.RabbitMQ.dll

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

Inheritance

object

AbstractBinder<IMessageChannel>

AbstractMessageChannelBinder

AbstractPollableMessageSourceBinder

RabbitMessageChannelBinder

Implements

IBinder<IMessageChannel>

IPollableConsumerBinder<IMessageHandler>

IBinder<IPollableSource<IMessageHandler>>

IBinder

IServiceNameAware

IDisposable

IPollableConsumerBinder

Inherited Members

AbstractPollableMessageSourceBinder.BindConsumer(string, string, object, IConsumerOptions)

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

AbstractPollableMessageSourceBinder.BindProducer(string, IPollableSource<IMessageHandler>, IProducerOptions)

AbstractPollableMessageSourceBinder.GetPolledConsumerRecoveryCallback(AbstractMessageChannelBinder.ErrorInfrastructure, IConsumerOptions)

AbstractMessageChannelBinder._provisioningProvider

AbstractMessageChannelBinder._embeddedHeadersChannelInterceptor

AbstractMessageChannelBinder._headersToEmbed

AbstractMessageChannelBinder._producerBindingExist

AbstractMessageChannelBinder.TargetType

AbstractMessageChannelBinder.ListenerContainerCustomizer

AbstractMessageChannelBinder.MessageSourceCustomizer

AbstractMessageChannelBinder.DoBindProducer(string, IMessageChannel, IProducerOptions)

AbstractMessageChannelBinder.UseNativeEncoding(IProducerOptions)

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

AbstractMessageChannelBinder.AfterUnbindProducer(IProducerDestination, IProducerOptions)

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

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

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

AbstractMessageChannelBinder.GetDefaultErrorMessageHandler(ILastSubscriberAwareChannel, bool)

AbstractMessageChannelBinder.GetErrorRecovererName(IConsumerDestination, string, IConsumerOptions)

AbstractMessageChannelBinder.GetErrorMessageHandlerName(IConsumerDestination, string, IConsumerOptions)

AbstractMessageChannelBinder.GetErrorsBaseName(IProducerDestination)

AbstractMessageChannelBinder.GetErrorBridgeName(IConsumerDestination, string, IConsumerOptions)

AbstractMessageChannelBinder.GetErrorBridgeName(IProducerDestination)

AbstractBinder<IMessageChannel>.ApplicationContext

AbstractBinder<IMessageChannel>.ApplyPrefix(string, string)

AbstractBinder<IMessageChannel>.ConstructDLQName(string)

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

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

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

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

RabbitMessageChannelBinder(IApplicationContext, ILogger<RabbitMessageChannelBinder>, IConnectionFactory, IOptionsMonitor<RabbitOptions>, IOptionsMonitor<RabbitBinderOptions>, IOptionsMonitor<RabbitBindingsOptions>, RabbitExchangeQueueProvisioner)

public RabbitMessageChannelBinder(IApplicationContext context, ILogger<RabbitMessageChannelBinder> logger, IConnectionFactory connectionFactory, IOptionsMonitor<RabbitOptions> rabbitOptions, IOptionsMonitor<RabbitBinderOptions> binderOptions, IOptionsMonitor<RabbitBindingsOptions> bindingsOptions, RabbitExchangeQueueProvisioner provisioningProvider)

Parameters

context IApplicationContext

logger ILogger<RabbitMessageChannelBinder>

connectionFactory IConnectionFactory

rabbitOptions IOptionsMonitor<RabbitOptions>

binderOptions IOptionsMonitor<RabbitBinderOptions>

bindingsOptions IOptionsMonitor<RabbitBindingsOptions>

provisioningProvider RabbitExchangeQueueProvisioner

RabbitMessageChannelBinder(IApplicationContext, ILogger<RabbitMessageChannelBinder>, IConnectionFactory, IOptionsMonitor<RabbitOptions>, IOptionsMonitor<RabbitBinderOptions>, IOptionsMonitor<RabbitBindingsOptions>, RabbitExchangeQueueProvisioner, IListenerContainerCustomizer)

public RabbitMessageChannelBinder(IApplicationContext context, ILogger<RabbitMessageChannelBinder> logger, IConnectionFactory connectionFactory, IOptionsMonitor<RabbitOptions> rabbitOptions, IOptionsMonitor<RabbitBinderOptions> binderOptions, IOptionsMonitor<RabbitBindingsOptions> bindingsOptions, RabbitExchangeQueueProvisioner provisioningProvider, IListenerContainerCustomizer containerCustomizer)

Parameters

context IApplicationContext

logger ILogger<RabbitMessageChannelBinder>

connectionFactory IConnectionFactory

rabbitOptions IOptionsMonitor<RabbitOptions>

binderOptions IOptionsMonitor<RabbitBinderOptions>

bindingsOptions IOptionsMonitor<RabbitBindingsOptions>

provisioningProvider RabbitExchangeQueueProvisioner

containerCustomizer IListenerContainerCustomizer

RabbitMessageChannelBinder(IApplicationContext, ILogger<RabbitMessageChannelBinder>, IConnectionFactory, IOptionsMonitor<RabbitOptions>, IOptionsMonitor<RabbitBinderOptions>, IOptionsMonitor<RabbitBindingsOptions>, RabbitExchangeQueueProvisioner, IListenerContainerCustomizer, IMessageSourceCustomizer)

public RabbitMessageChannelBinder(IApplicationContext context, ILogger<RabbitMessageChannelBinder> logger, IConnectionFactory connectionFactory, IOptionsMonitor<RabbitOptions> rabbitOptions, IOptionsMonitor<RabbitBinderOptions> binderOptions, IOptionsMonitor<RabbitBindingsOptions> bindingsOptions, RabbitExchangeQueueProvisioner provisioningProvider, IListenerContainerCustomizer containerCustomizer, IMessageSourceCustomizer sourceCustomizer)

Parameters

context IApplicationContext

logger ILogger<RabbitMessageChannelBinder>

connectionFactory IConnectionFactory

rabbitOptions IOptionsMonitor<RabbitOptions>

binderOptions IOptionsMonitor<RabbitBinderOptions>

bindingsOptions IOptionsMonitor<RabbitBindingsOptions>

provisioningProvider RabbitExchangeQueueProvisioner

containerCustomizer IListenerContainerCustomizer

sourceCustomizer IMessageSourceCustomizer

Fields

_logger

protected ILogger _logger

Field Value

ILogger

Properties

AdminAddresses

public string[] AdminAddresses { get; set; }

Property Value

string[]

BinderOptions

public RabbitBinderOptions BinderOptions { get; }

Property Value

RabbitBinderOptions

BindingsOptions

public RabbitBindingsOptions BindingsOptions { get; }

Property Value

RabbitBindingsOptions

Clustered

public bool Clustered { get; }

Property Value

bool

CompressingPostProcessor

public IMessagePostProcessor CompressingPostProcessor { get; set; }

Property Value

IMessagePostProcessor

ConnectionFactory

public IConnectionFactory ConnectionFactory { get; }

Property Value

IConnectionFactory

DecompressingPostProcessor

public IMessagePostProcessor DecompressingPostProcessor { get; set; }

Property Value

IMessagePostProcessor

Nodes

public string[] Nodes { get; set; }

Property Value

string[]

ProvisioningProvider

protected RabbitExchangeQueueProvisioner ProvisioningProvider { get; }

Property Value

RabbitExchangeQueueProvisioner

RabbitConnectionOptions

public IOptionsMonitor<RabbitOptions> RabbitConnectionOptions { get; }

Property Value

IOptionsMonitor<RabbitOptions>

ServiceName

public override string ServiceName { get; set; }

Property Value

string

Methods

AfterUnbindConsumer(IConsumerDestination, string, IConsumerOptions)

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

Parameters

destination IConsumerDestination

group string

consumerOptions IConsumerOptions

CreateConsumerEndpoint(IConsumerDestination, string, IConsumerOptions)

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

Parameters

destination IConsumerDestination

group string

consumerOptions IConsumerOptions

Returns

IMessageProducer

CreatePolledConsumerResources(string, string, IConsumerDestination, IConsumerOptions)

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

Parameters

name string

group string

destination IConsumerDestination

consumerOptions IConsumerOptions

Returns

AbstractMessageChannelBinder.PolledConsumerResources

CreateProducerMessageHandler(IProducerDestination, IProducerOptions, IMessageChannel)

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

Parameters

destination IProducerDestination

producerProperties IProducerOptions

errorChannel IMessageChannel

Returns

IMessageHandler

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public override void Dispose()

GetConsumerOptions(string)

public RabbitConsumerOptions GetConsumerOptions(string channelName)

Parameters

channelName string

Returns

RabbitConsumerOptions

GetErrorMessageHandler(IConsumerDestination, string, IConsumerOptions)

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

Parameters

destination IConsumerDestination

group string

consumerOptions IConsumerOptions

Returns

IMessageHandler

GetErrorMessageStrategy()

protected override IErrorMessageStrategy GetErrorMessageStrategy()

Returns

IErrorMessageStrategy

GetErrorsBaseName(IConsumerDestination, string, IConsumerOptions)

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

Parameters

destination IConsumerDestination

group string

consumerOptions IConsumerOptions

Returns

string

GetPolledConsumerErrorMessageHandler(IConsumerDestination, string, IConsumerOptions)

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

Parameters

destination IConsumerDestination

group string

consumerProperties IConsumerOptions

Returns

IMessageHandler

GetProducerOptions(string)

public RabbitProducerOptions GetProducerOptions(string channelName)

Parameters

channelName string

Returns

RabbitProducerOptions

Initialize()

public void Initialize()

PostProcessOutputChannel(IMessageChannel, IProducerOptions)

protected override void PostProcessOutputChannel(IMessageChannel outputChannel, IProducerOptions producerOptions)

Parameters

outputChannel IMessageChannel

producerOptions IProducerOptions

PostProcessPollableSource(DefaultPollableMessageSource)

protected override void PostProcessPollableSource(DefaultPollableMessageSource bindingTarget)

Parameters

bindingTarget DefaultPollableMessageSource