Class RabbitMessageChannelBinder

Inheritance

System.Object

AbstractBinder<IMessageChannel>

AbstractMessageChannelBinder

AbstractPollableMessageSourceBinder

RabbitMessageChannelBinder

Implements

IBinder<IMessageChannel>

IPollableConsumerBinder<IMessageHandler>

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)

AbstractPollableMessageSourceBinder.CreatePolledConsumerResources(String, String, IConsumerDestination, IConsumerOptions)

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, Boolean, ILogger)

AbstractMessageChannelBinder.GetErrorMessageHandler(IConsumerDestination, String, IConsumerOptions)

AbstractMessageChannelBinder.GetPolledConsumerErrorMessageHandler(IConsumerDestination, String, IConsumerOptions)

AbstractMessageChannelBinder.GetDefaultErrorMessageHandler(ILastSubscriberAwareChannel, Boolean)

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>.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)

Steeltoe.Stream.Binder.AbstractBinder<IMessageChannel>.GetRetryableExceptions(List<>)

Namespace: Steeltoe.Stream.Binder.Rabbit

Assembly: Steeltoe.Stream.Binder.RabbitMQ.dll

Syntax

public class RabbitMessageChannelBinder : AbstractPollableMessageSourceBinder

Constructors

| Edit this page View Source

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

Declaration

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

Parameters

Type	Name	Description
IApplicationContext	context
ILogger<RabbitMessageChannelBinder>	logger
IConnectionFactory	connectionFactory
IOptionsMonitor<RabbitOptions>	rabbitOptions
IOptionsMonitor<RabbitBinderOptions>	binderOptions
IOptionsMonitor<RabbitBindingsOptions>	bindingsOptions
RabbitExchangeQueueProvisioner	provisioningProvider

| Edit this page View Source

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

Declaration

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

Parameters

Type	Name	Description
IApplicationContext	context
ILogger<RabbitMessageChannelBinder>	logger
IConnectionFactory	connectionFactory
IOptionsMonitor<RabbitOptions>	rabbitOptions
IOptionsMonitor<RabbitBinderOptions>	binderOptions
IOptionsMonitor<RabbitBindingsOptions>	bindingsOptions
RabbitExchangeQueueProvisioner	provisioningProvider
IListenerContainerCustomizer	containerCustomizer

| Edit this page View Source

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

Declaration

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

Type	Name	Description
IApplicationContext	context
ILogger<RabbitMessageChannelBinder>	logger
IConnectionFactory	connectionFactory
IOptionsMonitor<RabbitOptions>	rabbitOptions
IOptionsMonitor<RabbitBinderOptions>	binderOptions
IOptionsMonitor<RabbitBindingsOptions>	bindingsOptions
RabbitExchangeQueueProvisioner	provisioningProvider
IListenerContainerCustomizer	containerCustomizer
IMessageSourceCustomizer	sourceCustomizer

Fields

| Edit this page View Source

_logger

Declaration

protected ILogger _logger

Field Value

Type	Description
ILogger

Properties

| Edit this page View Source

AdminAddresses

Declaration

public string[] AdminAddresses { get; set; }

Property Value

Type	Description
System.String[]

| Edit this page View Source

BinderOptions

Declaration

public RabbitBinderOptions BinderOptions { get; }

Property Value

Type	Description
RabbitBinderOptions

| Edit this page View Source

BindingsOptions

Declaration

public RabbitBindingsOptions BindingsOptions { get; }

Property Value

Type	Description
RabbitBindingsOptions

| Edit this page View Source

Clustered

Declaration

public bool Clustered { get; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

CompressingPostProcessor

Declaration

public IMessagePostProcessor CompressingPostProcessor { get; set; }

Property Value

Type	Description
IMessagePostProcessor

| Edit this page View Source

ConnectionFactory

Declaration

public IConnectionFactory ConnectionFactory { get; }

Property Value

Type	Description
IConnectionFactory

| Edit this page View Source

DecompressingPostProcessor

Declaration

public IMessagePostProcessor DecompressingPostProcessor { get; set; }

Property Value

Type	Description
IMessagePostProcessor

| Edit this page View Source

Nodes

Declaration

public string[] Nodes { get; set; }

Property Value

Type	Description
System.String[]

| Edit this page View Source

ProvisioningProvider

Declaration

protected RabbitExchangeQueueProvisioner ProvisioningProvider { get; }

Property Value

Type	Description
RabbitExchangeQueueProvisioner

| Edit this page View Source

RabbitConnectionOptions

Declaration

public IOptionsMonitor<RabbitOptions> RabbitConnectionOptions { get; }

Property Value

Type	Description
IOptionsMonitor<RabbitOptions>

| Edit this page View Source

ServiceName

Declaration

public override string ServiceName { get; set; }

Property Value

Type	Description
System.String

Overrides

Steeltoe.Stream.Binder.AbstractBinder<IMessageChannel>.ServiceName

Methods

| Edit this page View Source

AfterUnbindConsumer(IConsumerDestination, String, IConsumerOptions)

Declaration

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

Parameters

Type	Name	Description
IConsumerDestination	destination
System.String	group
IConsumerOptions	consumerOptions

| Edit this page View Source

CreateConsumerEndpoint(IConsumerDestination, String, IConsumerOptions)

Declaration

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

Parameters

Type	Name	Description
IConsumerDestination	destination
System.String	group
IConsumerOptions	consumerOptions

Returns

Type	Description
IMessageProducer

| Edit this page View Source

CreatePolledConsumerResources(String, String, IConsumerDestination, IConsumerOptions)

Declaration

protected override 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

CreateProducerMessageHandler(IProducerDestination, IProducerOptions, IMessageChannel)

Declaration

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

Parameters

Type	Name	Description
IProducerDestination	destination
IProducerOptions	producerProperties
IMessageChannel	errorChannel

Returns

Type	Description
IMessageHandler

| Edit this page View Source

Dispose()

Declaration

public override void Dispose()

Overrides

Steeltoe.Stream.Binder.AbstractBinder<IMessageChannel>.Dispose()

| Edit this page View Source

GetConsumerOptions(String)

Declaration

public RabbitConsumerOptions GetConsumerOptions(string channelName)

Parameters

Type	Name	Description
System.String	channelName

Returns

Type	Description
RabbitConsumerOptions

| Edit this page View Source

GetErrorMessageHandler(IConsumerDestination, String, IConsumerOptions)

Declaration

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

Parameters

Type	Name	Description
IConsumerDestination	destination
System.String	group
IConsumerOptions	consumerOptions

Returns

Type	Description
IMessageHandler

| Edit this page View Source

GetErrorMessageStrategy()

Declaration

protected override IErrorMessageStrategy GetErrorMessageStrategy()

Returns

Type	Description
IErrorMessageStrategy

Overrides

AbstractMessageChannelBinder.GetErrorMessageStrategy()

| Edit this page View Source

GetErrorsBaseName(IConsumerDestination, String, IConsumerOptions)

Declaration

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

Parameters

Type	Name	Description
IConsumerDestination	destination
System.String	group
IConsumerOptions	consumerOptions

Returns

Type	Description
System.String

| Edit this page View Source

GetPolledConsumerErrorMessageHandler(IConsumerDestination, String, IConsumerOptions)

Declaration

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

Parameters

Type	Name	Description
IConsumerDestination	destination
System.String	group
IConsumerOptions	consumerProperties

Returns

Type	Description
IMessageHandler

| Edit this page View Source

GetProducerOptions(String)

Declaration

public RabbitProducerOptions GetProducerOptions(string channelName)

Parameters

Type	Name	Description
System.String	channelName

Returns

Type	Description
RabbitProducerOptions

| Edit this page View Source

Initialize()

Declaration

public void Initialize()

| Edit this page View Source

PostProcessOutputChannel(IMessageChannel, IProducerOptions)

Declaration

protected override void PostProcessOutputChannel(IMessageChannel outputChannel, IProducerOptions producerOptions)

Parameters

Type	Name	Description
IMessageChannel	outputChannel
IProducerOptions	producerOptions

| Edit this page View Source

PostProcessPollableSource(DefaultPollableMessageSource)

Declaration

protected override void PostProcessPollableSource(DefaultPollableMessageSource bindingTarget)

Parameters

Type	Name	Description
DefaultPollableMessageSource	bindingTarget

Overrides

AbstractPollableMessageSourceBinder.PostProcessPollableSource(DefaultPollableMessageSource)

Implements

IBinder<T>

IPollableConsumerBinder<H>