X

Class AbstractMessageListenerContainer

Inheritance
System.Object
AbstractMessageListenerContainer
DirectMessageListenerContainer
Implements
ISmartLifecycle
IDisposable
IServiceNameAware
Namespace: Steeltoe.Messaging.RabbitMQ.Listener
Assembly: Steeltoe.Messaging.RabbitMQ.dll
Syntax
public abstract class AbstractMessageListenerContainer : object, IMessageListenerContainer

Constructors

| Edit this page View Source

AbstractMessageListenerContainer(IApplicationContext, IConnectionFactory, String, ILoggerFactory)

Declaration
protected AbstractMessageListenerContainer(IApplicationContext applicationContext, IConnectionFactory connectionFactory, string name = null, ILoggerFactory loggerFactory = null)
Parameters
Type Name Description
IApplicationContext applicationContext
IConnectionFactory connectionFactory
System.String name
ILoggerFactory loggerFactory

Fields

| Edit this page View Source

_consumersMonitor

Declaration
protected readonly object _consumersMonitor
Field Value
Type Description
System.Object
| Edit this page View Source

_lifecycleMonitor

Declaration
protected readonly object _lifecycleMonitor
Field Value
Type Description
System.Object
| Edit this page View Source

_lock

Declaration
protected readonly object _lock
Field Value
Type Description
System.Object
| Edit this page View Source

_logger

Declaration
protected readonly ILogger _logger
Field Value
Type Description
ILogger
| Edit this page View Source

_loggerFactory

Declaration
protected readonly ILoggerFactory _loggerFactory
Field Value
Type Description
ILoggerFactory
| Edit this page View Source

_recoveryInterval

Declaration
protected int _recoveryInterval
Field Value
Type Description
System.Int32
| Edit this page View Source

DEFAULT_DEBATCHING_ENABLED

Declaration
public const bool DEFAULT_DEBATCHING_ENABLED = null
Field Value
Type Description
System.Boolean
| Edit this page View Source

DEFAULT_FAILED_DECLARATION_RETRY_INTERVAL

Declaration
public const int DEFAULT_FAILED_DECLARATION_RETRY_INTERVAL = null
Field Value
Type Description
System.Int32
| Edit this page View Source

DEFAULT_PREFETCH_COUNT

Declaration
public const int DEFAULT_PREFETCH_COUNT = null
Field Value
Type Description
System.Int32
| Edit this page View Source

DEFAULT_RECOVERY_INTERVAL

Declaration
public const int DEFAULT_RECOVERY_INTERVAL = null
Field Value
Type Description
System.Int32
| Edit this page View Source

DEFAULT_SHUTDOWN_TIMEOUT

Declaration
public const long DEFAULT_SHUTDOWN_TIMEOUT = null
Field Value
Type Description
System.Int64

Properties

| Edit this page View Source

AcknowledgeMode

Declaration
public virtual AcknowledgeMode AcknowledgeMode { get; set; }
Property Value
Type Description
AcknowledgeMode
| Edit this page View Source

AfterReceivePostProcessors

Declaration
public virtual IList<IMessagePostProcessor> AfterReceivePostProcessors { get; }
Property Value
Type Description
IList<IMessagePostProcessor>
| Edit this page View Source

AlwaysRequeueWithTxManagerRollback

Declaration
public virtual bool AlwaysRequeueWithTxManagerRollback { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

ApplicationContext

Declaration
public IApplicationContext ApplicationContext { get; set; }
Property Value
Type Description
IApplicationContext
| Edit this page View Source

AutoDeclare

Declaration
public virtual bool AutoDeclare { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

BatchingStrategy

Declaration
public virtual IBatchingStrategy BatchingStrategy { get; set; }
Property Value
Type Description
IBatchingStrategy
| Edit this page View Source

ConnectionFactory

Declaration
public virtual IConnectionFactory ConnectionFactory { get; set; }
Property Value
Type Description
IConnectionFactory
| Edit this page View Source

ConsumerArguments

Declaration
public virtual Dictionary<string, object> ConsumerArguments { get; set; }
Property Value
Type Description
Dictionary<System.String, System.Object>
| Edit this page View Source

ConsumerTagStrategy

Declaration
public virtual IConsumerTagStrategy ConsumerTagStrategy { get; set; }
Property Value
Type Description
IConsumerTagStrategy
| Edit this page View Source

DefaultRequeueRejected

Declaration
public virtual bool DefaultRequeueRejected { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

ErrorHandler

Declaration
public virtual IErrorHandler ErrorHandler { get; set; }
Property Value
Type Description
IErrorHandler
| Edit this page View Source

Exclusive

Declaration
public virtual bool Exclusive { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

ExclusiveConsumerExceptionLogger

Declaration
public virtual IConditionalExceptionLogger ExclusiveConsumerExceptionLogger { get; set; }
Property Value
Type Description
IConditionalExceptionLogger
| Edit this page View Source

ExposeListenerChannel

Declaration
public virtual bool ExposeListenerChannel { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

FailedDeclarationRetryInterval

Declaration
public virtual long FailedDeclarationRetryInterval { get; set; }
Property Value
Type Description
System.Int64
| Edit this page View Source

ForceCloseChannel

Declaration
protected virtual bool ForceCloseChannel { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

IdleEventInterval

Declaration
public virtual long IdleEventInterval { get; set; }
Property Value
Type Description
System.Int64
| Edit this page View Source

Initialized

Declaration
public virtual bool Initialized { get; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

IsActive

Declaration
public virtual bool IsActive { get; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

IsAutoStartup

Declaration
public virtual bool IsAutoStartup { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

IsChannelLocallyTransacted

Declaration
protected virtual bool IsChannelLocallyTransacted { get; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

IsChannelTransacted

Declaration
public virtual bool IsChannelTransacted { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

IsDeBatchingEnabled

Declaration
public virtual bool IsDeBatchingEnabled { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

IsLazyLoad

Declaration
public virtual bool IsLazyLoad { get; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

IsRunning

Declaration
public virtual bool IsRunning { get; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

LastReceive

Declaration
protected virtual long LastReceive { get; }
Property Value
Type Description
System.Int64
| Edit this page View Source

ListenerId

Declaration
public virtual string ListenerId { get; set; }
Property Value
Type Description
System.String
| Edit this page View Source

LookupKeyQualifier

Declaration
public virtual string LookupKeyQualifier { get; set; }
Property Value
Type Description
System.String
| Edit this page View Source

MessageHeadersConverter

Declaration
public virtual IMessageHeadersConverter MessageHeadersConverter { get; set; }
Property Value
Type Description
IMessageHeadersConverter
| Edit this page View Source

MessageListener

Declaration
public virtual IMessageListener MessageListener { get; set; }
Property Value
Type Description
IMessageListener
| Edit this page View Source

MismatchedQueuesFatal

Declaration
public virtual bool MismatchedQueuesFatal { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

MissingQueuesFatal

Declaration
public virtual bool MissingQueuesFatal { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

NoLocal

Declaration
public virtual bool NoLocal { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

Phase

Declaration
public virtual int Phase { get; set; }
Property Value
Type Description
System.Int32
| Edit this page View Source

PossibleAuthenticationFailureFatal

Declaration
public virtual bool PossibleAuthenticationFailureFatal { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

PrefetchCount

Declaration
public virtual int PrefetchCount { get; set; }
Property Value
Type Description
System.Int32
| Edit this page View Source

RabbitAdmin

Declaration
public virtual IRabbitAdmin RabbitAdmin { get; set; }
Property Value
Type Description
IRabbitAdmin
| Edit this page View Source

RecoveryBackOff

Declaration
public IBackOff RecoveryBackOff { get; set; }
Property Value
Type Description
IBackOff
| Edit this page View Source

RecoveryInterval

Declaration
public virtual int RecoveryInterval { get; set; }
Property Value
Type Description
System.Int32
| Edit this page View Source

ServiceName

Declaration
public virtual string ServiceName { get; set; }
Property Value
Type Description
System.String
| Edit this page View Source

ShutdownTimeout

Declaration
public virtual long ShutdownTimeout { get; set; }
Property Value
Type Description
System.Int64
| Edit this page View Source

StatefulRetryFatalWithNullMessageId

Declaration
public virtual bool StatefulRetryFatalWithNullMessageId { get; set; }
Property Value
Type Description
System.Boolean
| Edit this page View Source

TransactionAttribute

Declaration
public virtual ITransactionAttribute TransactionAttribute { get; set; }
Property Value
Type Description
ITransactionAttribute
| Edit this page View Source

TransactionManager

Declaration
public virtual IPlatformTransactionManager TransactionManager { get; set; }
Property Value
Type Description
IPlatformTransactionManager

Methods

| Edit this page View Source

ActualInvokeListener(RabbitMQ.Client.IModel, IMessage)

Declaration
protected virtual void ActualInvokeListener(RabbitMQ.Client.IModel channel, IMessage message)
Parameters
Type Name Description
RabbitMQ.Client.IModel channel
IMessage message
| Edit this page View Source

ActualInvokeListener(RabbitMQ.Client.IModel, List<IMessage>)

Declaration
protected virtual void ActualInvokeListener(RabbitMQ.Client.IModel channel, List<IMessage> data)
Parameters
Type Name Description
RabbitMQ.Client.IModel channel
List<IMessage> data
| Edit this page View Source

AddAfterReceivePostProcessors(IMessagePostProcessor[])

Declaration
public virtual void AddAfterReceivePostProcessors(params IMessagePostProcessor[] afterReceivePostProcessors)
Parameters
Type Name Description
IMessagePostProcessor[] afterReceivePostProcessors
| Edit this page View Source

AddQueueNames(String[])

Declaration
public virtual void AddQueueNames(params string[] queueNames)
Parameters
Type Name Description
System.String[] queueNames
| Edit this page View Source

AddQueues(IQueue[])

Declaration
public virtual void AddQueues(params IQueue[] queues)
Parameters
Type Name Description
IQueue[] queues
| Edit this page View Source

CauseChainHasImmediateAcknowledgeRabbitException(Exception)

Declaration
protected virtual bool CauseChainHasImmediateAcknowledgeRabbitException(Exception exception)
Parameters
Type Name Description
Exception exception
Returns
Type Description
System.Boolean
| Edit this page View Source

CheckMessageListener(Object)

Declaration
protected virtual void CheckMessageListener(object listener)
Parameters
Type Name Description
System.Object listener
| Edit this page View Source

CheckMismatchedQueues()

Declaration
protected virtual void CheckMismatchedQueues()
| Edit this page View Source

ConfigureAdminIfNeeded()

Declaration
protected virtual void ConfigureAdminIfNeeded()
| Edit this page View Source

ConvertRabbitAccessException(Exception)

Declaration
protected virtual Exception ConvertRabbitAccessException(Exception ex)
Parameters
Type Name Description
Exception ex
Returns
Type Description
Exception
| Edit this page View Source

CreateConnection()

Declaration
protected virtual IConnection CreateConnection()
Returns
Type Description
IConnection
| Edit this page View Source

Dispose()

Declaration
public virtual void Dispose()
| Edit this page View Source

DoInitialize()

Declaration
protected abstract void DoInitialize()
| Edit this page View Source

DoInvokeListener(IChannelAwareMessageListener, RabbitMQ.Client.IModel, IMessage)

Declaration
protected virtual void DoInvokeListener(IChannelAwareMessageListener listener, RabbitMQ.Client.IModel channel, IMessage message)
Parameters
Type Name Description
IChannelAwareMessageListener listener
RabbitMQ.Client.IModel channel
IMessage message
| Edit this page View Source

DoInvokeListener(IChannelAwareMessageListener, RabbitMQ.Client.IModel, List<IMessage>)

Declaration
protected virtual void DoInvokeListener(IChannelAwareMessageListener listener, RabbitMQ.Client.IModel channel, List<IMessage> data)
Parameters
Type Name Description
IChannelAwareMessageListener listener
RabbitMQ.Client.IModel channel
List<IMessage> data
| Edit this page View Source

DoInvokeListener(IMessageListener, IMessage)

Declaration
protected virtual void DoInvokeListener(IMessageListener listener, IMessage message)
Parameters
Type Name Description
IMessageListener listener
IMessage message
| Edit this page View Source

DoInvokeListener(IMessageListener, List<IMessage>)

Declaration
protected virtual void DoInvokeListener(IMessageListener listener, List<IMessage> data)
Parameters
Type Name Description
IMessageListener listener
List<IMessage> data
| Edit this page View Source

DoShutdown()

Declaration
protected abstract void DoShutdown()
| Edit this page View Source

DoStart()

Declaration
protected virtual void DoStart()
| Edit this page View Source

DoStop()

Declaration
protected virtual void DoStop()
| Edit this page View Source

ExecuteListener(RabbitMQ.Client.IModel, IMessage)

Declaration
protected virtual void ExecuteListener(RabbitMQ.Client.IModel channel, IMessage message)
Parameters
Type Name Description
RabbitMQ.Client.IModel channel
IMessage message
| Edit this page View Source

GetConnectionFactory()

Declaration
public virtual IConnectionFactory GetConnectionFactory()
Returns
Type Description
IConnectionFactory
| Edit this page View Source

GetQueueNames()

Declaration
public virtual string[] GetQueueNames()
Returns
Type Description
System.String[]
| Edit this page View Source

GetQueueNamesAsSet()

Declaration
protected virtual ISet<string> GetQueueNamesAsSet()
Returns
Type Description
ISet<System.String>
| Edit this page View Source

GetQueueNamesToQueues()

Declaration
protected virtual Dictionary<string, IQueue> GetQueueNamesToQueues()
Returns
Type Description
Dictionary<System.String, IQueue>
| Edit this page View Source

GetRoutingConnectionFactory()

Declaration
protected virtual IRoutingConnectionFactory GetRoutingConnectionFactory()
Returns
Type Description
IRoutingConnectionFactory
| Edit this page View Source

GetRoutingLookupKey()

Declaration
protected virtual string GetRoutingLookupKey()
Returns
Type Description
System.String
| Edit this page View Source

GetTransactionalResourceHolder()

Declaration
protected virtual RabbitResourceHolder GetTransactionalResourceHolder()
Returns
Type Description
RabbitResourceHolder
| Edit this page View Source

HandleChannelAwareTransaction(RabbitMQ.Client.IModel, out RabbitMQ.Client.IModel, out RabbitResourceHolder)

Declaration
protected virtual bool HandleChannelAwareTransaction(RabbitMQ.Client.IModel channel, out RabbitMQ.Client.IModel channelToUse, out RabbitResourceHolder resourceHolder)
Parameters
Type Name Description
RabbitMQ.Client.IModel channel
RabbitMQ.Client.IModel channelToUse
RabbitResourceHolder resourceHolder
Returns
Type Description
System.Boolean
| Edit this page View Source

HandleListenerException(Exception)

Declaration
protected virtual void HandleListenerException(Exception exception)
Parameters
Type Name Description
Exception exception
| Edit this page View Source

Initialize()

Declaration
public virtual void Initialize()
| Edit this page View Source

InvokeErrorHandler(Exception)

Declaration
protected virtual void InvokeErrorHandler(Exception ex)
Parameters
Type Name Description
Exception ex
| Edit this page View Source

LazyLoad()

Declaration
public virtual void LazyLoad()
| Edit this page View Source

PrepareHolderForRollback(RabbitResourceHolder, Exception)

Declaration
protected virtual void PrepareHolderForRollback(RabbitResourceHolder resourceHolder, Exception exception)
Parameters
Type Name Description
RabbitResourceHolder resourceHolder
Exception exception
| Edit this page View Source

RedeclareElementsIfNecessary()

Declaration
protected virtual void RedeclareElementsIfNecessary()
| Edit this page View Source

RemoveAfterReceivePostProcessor(IMessagePostProcessor)

Declaration
public virtual bool RemoveAfterReceivePostProcessor(IMessagePostProcessor afterReceivePostProcessor)
Parameters
Type Name Description
IMessagePostProcessor afterReceivePostProcessor
Returns
Type Description
System.Boolean
| Edit this page View Source

RemoveQueueNames(String[])

Declaration
public virtual bool RemoveQueueNames(params string[] queueNames)
Parameters
Type Name Description
System.String[] queueNames
Returns
Type Description
System.Boolean
| Edit this page View Source

RemoveQueues(IQueue[])

Declaration
public virtual void RemoveQueues(params IQueue[] queues)
Parameters
Type Name Description
IQueue[] queues
| Edit this page View Source

SetAfterReceivePostProcessors(IMessagePostProcessor[])

Declaration
public virtual void SetAfterReceivePostProcessors(params IMessagePostProcessor[] afterReceivePostProcessors)
Parameters
Type Name Description
IMessagePostProcessor[] afterReceivePostProcessors
| Edit this page View Source

SetQueueNames(String[])

Declaration
public virtual void SetQueueNames(params string[] queueNames)
Parameters
Type Name Description
System.String[] queueNames
| Edit this page View Source

SetQueues(IQueue[])

Declaration
public virtual void SetQueues(params IQueue[] queues)
Parameters
Type Name Description
IQueue[] queues
| Edit this page View Source

SetupMessageListener(IMessageListener)

Declaration
public virtual void SetupMessageListener(IMessageListener messageListener)
Parameters
Type Name Description
IMessageListener messageListener
| Edit this page View Source

Shutdown()

Declaration
public virtual void Shutdown()
| Edit this page View Source

Start()

Declaration
public virtual Task Start()
Returns
Type Description
Task
| Edit this page View Source

Stop()

Declaration
public virtual Task Stop()
Returns
Type Description
Task
| Edit this page View Source

Stop(Action)

Declaration
public virtual Task Stop(Action callback)
Parameters
Type Name Description
Action callback
Returns
Type Description
Task
| Edit this page View Source

UpdateLastReceive()

Declaration
protected virtual void UpdateLastReceive()
| Edit this page View Source

ValidateConfiguration()

Declaration
protected virtual void ValidateConfiguration()
| Edit this page View Source

WrapToListenerExecutionFailedExceptionIfNeeded(Exception, IMessage)

Declaration
protected virtual ListenerExecutionFailedException WrapToListenerExecutionFailedExceptionIfNeeded(Exception exception, IMessage message)
Parameters
Type Name Description
Exception exception
IMessage message
Returns
Type Description
ListenerExecutionFailedException
| Edit this page View Source

WrapToListenerExecutionFailedExceptionIfNeeded(Exception, List<IMessage>)

Declaration
protected virtual ListenerExecutionFailedException WrapToListenerExecutionFailedExceptionIfNeeded(Exception exception, List<IMessage> data)
Parameters
Type Name Description
Exception exception
List<IMessage> data
Returns
Type Description
ListenerExecutionFailedException

Implements

ISmartLifecycle
IDisposable
IServiceNameAware