Class AbstractRabbitListenerContainerFactory<C>

Namespace

Steeltoe.Messaging.RabbitMQ.Config

Assembly

Steeltoe.Messaging.RabbitMQ.dll

public abstract class AbstractRabbitListenerContainerFactory<C> : IRabbitListenerContainerFactory<C>, IRabbitListenerContainerFactory, IServiceNameAware where C : AbstractMessageListenerContainer

Type Parameters

C

Inheritance

object

AbstractRabbitListenerContainerFactory<C>

Implements

IRabbitListenerContainerFactory<C>

IRabbitListenerContainerFactory

IServiceNameAware

Derived

DirectRabbitListenerContainerFactory

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

AbstractRabbitListenerContainerFactory(IApplicationContext, ILoggerFactory)

protected AbstractRabbitListenerContainerFactory(IApplicationContext applicationContext, ILoggerFactory loggerFactory = null)

Parameters

applicationContext IApplicationContext

loggerFactory ILoggerFactory

AbstractRabbitListenerContainerFactory(IApplicationContext, IOptionsMonitor<RabbitOptions>, IConnectionFactory, ILoggerFactory)

protected AbstractRabbitListenerContainerFactory(IApplicationContext applicationContext, IOptionsMonitor<RabbitOptions> optionsMonitor, IConnectionFactory connectionFactory, ILoggerFactory loggerFactory = null)

Parameters

applicationContext IApplicationContext

optionsMonitor IOptionsMonitor<RabbitOptions>

connectionFactory IConnectionFactory

loggerFactory ILoggerFactory

AbstractRabbitListenerContainerFactory(IApplicationContext, IConnectionFactory, ILoggerFactory)

protected AbstractRabbitListenerContainerFactory(IApplicationContext applicationContext, IConnectionFactory connectionFactory, ILoggerFactory loggerFactory = null)

Parameters

applicationContext IApplicationContext

connectionFactory IConnectionFactory

loggerFactory ILoggerFactory

Fields

_logger

protected readonly ILogger _logger

Field Value

ILogger

_loggerFactory

protected readonly ILoggerFactory _loggerFactory

Field Value

ILoggerFactory

Properties

AcknowledgeMode

public AcknowledgeMode? AcknowledgeMode { get; set; }

Property Value

AcknowledgeMode?

AfterReceivePostProcessors

public List<IMessagePostProcessor> AfterReceivePostProcessors { get; set; }

Property Value

List<IMessagePostProcessor>

ApplicationContext

public IApplicationContext ApplicationContext { get; set; }

Property Value

IApplicationContext

AutoStartup

public bool? AutoStartup { get; set; }

Property Value

bool?

BatchListener

public bool BatchListener { get; set; }

Property Value

bool

BatchingStrategy

public IBatchingStrategy BatchingStrategy { get; set; }

Property Value

IBatchingStrategy

BeforeSendReplyPostProcessors

public List<IMessagePostProcessor> BeforeSendReplyPostProcessors { get; set; }

Property Value

List<IMessagePostProcessor>

ConnectionFactory

public IConnectionFactory ConnectionFactory { get; set; }

Property Value

IConnectionFactory

ConsumerTagStrategy

public IConsumerTagStrategy ConsumerTagStrategy { get; set; }

Property Value

IConsumerTagStrategy

ContainerCustomizer

public Action<C> ContainerCustomizer { get; set; }

Property Value

Action<C>

DeBatchingEnabled

public bool? DeBatchingEnabled { get; set; }

Property Value

bool?

DefaultRequeueRejected

public bool? DefaultRequeueRejected { get; set; }

Property Value

bool?

ErrorHandler

public IErrorHandler ErrorHandler { get; set; }

Property Value

IErrorHandler

FailedDeclarationRetryInterval

public int? FailedDeclarationRetryInterval { get; set; }

Property Value

int?

IdleEventInterval

public int? IdleEventInterval { get; set; }

Property Value

int?

IsChannelTransacted

public bool? IsChannelTransacted { get; set; }

Property Value

bool?

MessageConverter

public ISmartMessageConverter MessageConverter { get; set; }

Property Value

ISmartMessageConverter

MismatchedQueuesFatal

public bool? MismatchedQueuesFatal { get; set; }

Property Value

bool?

MissingQueuesFatal

public bool? MissingQueuesFatal { get; set; }

Property Value

bool?

Options

protected RabbitOptions Options { get; }

Property Value

RabbitOptions

Phase

public int Phase { get; set; }

Property Value

int

PossibleAuthenticationFailureFatal

public bool PossibleAuthenticationFailureFatal { get; set; }

Property Value

bool

PrefetchCount

public int? PrefetchCount { get; set; }

Property Value

int?

RecoveryBackOff

public IBackOff RecoveryBackOff { get; set; }

Property Value

IBackOff

RecoveryInterval

public int? RecoveryInterval { get; set; }

Property Value

int?

ReplyRecoveryCallback

public IRecoveryCallback ReplyRecoveryCallback { get; set; }

Property Value

IRecoveryCallback

RetryTemplate

public RetryTemplate RetryTemplate { get; set; }

Property Value

RetryTemplate

ServiceName

public virtual string ServiceName { get; set; }

Property Value

string

TransactionManager

public IPlatformTransactionManager TransactionManager { get; set; }

Property Value

IPlatformTransactionManager

Methods

CreateContainerInstance()

protected abstract C CreateContainerInstance()

Returns

C

CreateListenerContainer(IRabbitListenerEndpoint)

public C CreateListenerContainer(IRabbitListenerEndpoint endpoint)

Parameters

endpoint IRabbitListenerEndpoint

Returns

C

InitializeContainer(C, IRabbitListenerEndpoint)

protected virtual void InitializeContainer(C instance, IRabbitListenerEndpoint endpoint)

Parameters

instance C

endpoint IRabbitListenerEndpoint

SetAfterReceivePostProcessors(params IMessagePostProcessor[])

public void SetAfterReceivePostProcessors(params IMessagePostProcessor[] postProcessors)

Parameters

postProcessors IMessagePostProcessor[]

SetBeforeSendReplyPostProcessors(params IMessagePostProcessor[])

public void SetBeforeSendReplyPostProcessors(params IMessagePostProcessor[] postProcessors)

Parameters

postProcessors IMessagePostProcessor[]