Class DirectMessageListenerContainer

Namespace

Steeltoe.Messaging.RabbitMQ.Listener

Assembly

Steeltoe.Messaging.RabbitMQ.dll

public class DirectMessageListenerContainer : AbstractMessageListenerContainer, IMessageListenerContainer, ISmartLifecycle, ILifecycle, IPhased, IDisposable, IServiceNameAware

Inheritance

object

AbstractMessageListenerContainer

DirectMessageListenerContainer

Implements

IMessageListenerContainer

ISmartLifecycle

ILifecycle

IPhased

IDisposable

IServiceNameAware

Derived

DirectReplyToMessageListenerContainer

Inherited Members

AbstractMessageListenerContainer.DEFAULT_FAILED_DECLARATION_RETRY_INTERVAL

AbstractMessageListenerContainer.DEFAULT_SHUTDOWN_TIMEOUT

AbstractMessageListenerContainer.DEFAULT_RECOVERY_INTERVAL

AbstractMessageListenerContainer.DEFAULT_DEBATCHING_ENABLED

AbstractMessageListenerContainer.DEFAULT_PREFETCH_COUNT

AbstractMessageListenerContainer._consumersMonitor

AbstractMessageListenerContainer._lock

AbstractMessageListenerContainer._lifecycleMonitor

AbstractMessageListenerContainer._logger

AbstractMessageListenerContainer._loggerFactory

AbstractMessageListenerContainer._recoveryInterval

AbstractMessageListenerContainer.ConnectionFactory

AbstractMessageListenerContainer.IsChannelTransacted

AbstractMessageListenerContainer.ApplicationContext

AbstractMessageListenerContainer.AcknowledgeMode

AbstractMessageListenerContainer.ServiceName

AbstractMessageListenerContainer.ExposeListenerChannel

AbstractMessageListenerContainer.MessageListener

AbstractMessageListenerContainer.ErrorHandler

AbstractMessageListenerContainer.IsDeBatchingEnabled

AbstractMessageListenerContainer.AfterReceivePostProcessors

AbstractMessageListenerContainer.IsAutoStartup

AbstractMessageListenerContainer.Phase

AbstractMessageListenerContainer.LookupKeyQualifier

AbstractMessageListenerContainer.ListenerId

AbstractMessageListenerContainer.ConsumerTagStrategy

AbstractMessageListenerContainer.ConsumerArguments

AbstractMessageListenerContainer.NoLocal

AbstractMessageListenerContainer.DefaultRequeueRejected

AbstractMessageListenerContainer.PrefetchCount

AbstractMessageListenerContainer.ShutdownTimeout

AbstractMessageListenerContainer.IdleEventInterval

AbstractMessageListenerContainer.RecoveryInterval

AbstractMessageListenerContainer.RecoveryBackOff

AbstractMessageListenerContainer.MessageHeadersConverter

AbstractMessageListenerContainer.RabbitAdmin

AbstractMessageListenerContainer.MissingQueuesFatal

AbstractMessageListenerContainer.MismatchedQueuesFatal

AbstractMessageListenerContainer.PossibleAuthenticationFailureFatal

AbstractMessageListenerContainer.AutoDeclare

AbstractMessageListenerContainer.FailedDeclarationRetryInterval

AbstractMessageListenerContainer.StatefulRetryFatalWithNullMessageId

AbstractMessageListenerContainer.ExclusiveConsumerExceptionLogger

AbstractMessageListenerContainer.AlwaysRequeueWithTxManagerRollback

AbstractMessageListenerContainer.BatchingStrategy

AbstractMessageListenerContainer.IsRunning

AbstractMessageListenerContainer.IsActive

AbstractMessageListenerContainer.IsLazyLoad

AbstractMessageListenerContainer.Initialized

AbstractMessageListenerContainer.TransactionManager

AbstractMessageListenerContainer.TransactionAttribute

AbstractMessageListenerContainer.GetQueueNames()

AbstractMessageListenerContainer.SetQueues(params IQueue[])

AbstractMessageListenerContainer.SetAfterReceivePostProcessors(params IMessagePostProcessor[])

AbstractMessageListenerContainer.AddAfterReceivePostProcessors(params IMessagePostProcessor[])

AbstractMessageListenerContainer.RemoveAfterReceivePostProcessor(IMessagePostProcessor)

AbstractMessageListenerContainer.SetupMessageListener(IMessageListener)

AbstractMessageListenerContainer.GetConnectionFactory()

AbstractMessageListenerContainer.Initialize()

AbstractMessageListenerContainer.Dispose()

AbstractMessageListenerContainer.Shutdown()

AbstractMessageListenerContainer.Start()

AbstractMessageListenerContainer.Stop()

AbstractMessageListenerContainer.Stop(Action)

AbstractMessageListenerContainer.LazyLoad()

AbstractMessageListenerContainer.CreateConnection()

AbstractMessageListenerContainer.GetTransactionalResourceHolder()

AbstractMessageListenerContainer.ConvertRabbitAccessException(Exception)

AbstractMessageListenerContainer.RedeclareElementsIfNecessary()

AbstractMessageListenerContainer.InvokeErrorHandler(Exception)

AbstractMessageListenerContainer.ExecuteListener(IModel, IMessage)

AbstractMessageListenerContainer.ActualInvokeListener(IModel, List<IMessage>)

AbstractMessageListenerContainer.ActualInvokeListener(IModel, IMessage)

AbstractMessageListenerContainer.DoInvokeListener(IChannelAwareMessageListener, IModel, List<IMessage>)

AbstractMessageListenerContainer.DoInvokeListener(IChannelAwareMessageListener, IModel, IMessage)

AbstractMessageListenerContainer.DoInvokeListener(IMessageListener, List<IMessage>)

AbstractMessageListenerContainer.DoInvokeListener(IMessageListener, IMessage)

AbstractMessageListenerContainer.HandleChannelAwareTransaction(IModel, out IModel, out RabbitResourceHolder)

AbstractMessageListenerContainer.WrapToListenerExecutionFailedExceptionIfNeeded(Exception, List<IMessage>)

AbstractMessageListenerContainer.WrapToListenerExecutionFailedExceptionIfNeeded(Exception, IMessage)

AbstractMessageListenerContainer.HandleListenerException(Exception)

AbstractMessageListenerContainer.UpdateLastReceive()

AbstractMessageListenerContainer.ConfigureAdminIfNeeded()

AbstractMessageListenerContainer.CheckMismatchedQueues()

AbstractMessageListenerContainer.IsChannelLocallyTransacted

AbstractMessageListenerContainer.DoStop()

AbstractMessageListenerContainer.ValidateConfiguration()

AbstractMessageListenerContainer.GetRoutingConnectionFactory()

AbstractMessageListenerContainer.LastReceive

AbstractMessageListenerContainer.ForceCloseChannel

AbstractMessageListenerContainer.GetRoutingLookupKey()

AbstractMessageListenerContainer.CheckMessageListener(object)

AbstractMessageListenerContainer.GetQueueNamesAsSet()

AbstractMessageListenerContainer.GetQueueNamesToQueues()

AbstractMessageListenerContainer.CauseChainHasImmediateAcknowledgeRabbitException(Exception)

AbstractMessageListenerContainer.PrepareHolderForRollback(RabbitResourceHolder, Exception)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

DirectMessageListenerContainer(IApplicationContext, IConnectionFactory, string, ILoggerFactory)

public DirectMessageListenerContainer(IApplicationContext applicationContext, IConnectionFactory connectionFactory, string name = null, ILoggerFactory loggerFactory = null)

Parameters

applicationContext IApplicationContext

connectionFactory IConnectionFactory

name string

loggerFactory ILoggerFactory

DirectMessageListenerContainer(IApplicationContext, string, ILoggerFactory)

public DirectMessageListenerContainer(IApplicationContext applicationContext, string name = null, ILoggerFactory loggerFactory = null)

Parameters

applicationContext IApplicationContext

name string

loggerFactory ILoggerFactory

DirectMessageListenerContainer(string, ILoggerFactory)

public DirectMessageListenerContainer(string name = null, ILoggerFactory loggerFactory = null)

Parameters

name string

loggerFactory ILoggerFactory

Fields

DEFAULT_ACK_TIMEOUT

protected const int DEFAULT_ACK_TIMEOUT = 20000

Field Value

int

DEFAULT_MONITOR_INTERVAL

protected const int DEFAULT_MONITOR_INTERVAL = 10000

Field Value

int

START_WAIT_TIME

protected const int START_WAIT_TIME = 60

Field Value

int

_cancellationLock

protected readonly ActiveObjectCounter<DirectMessageListenerContainer.SimpleConsumer> _cancellationLock

Field Value

ActiveObjectCounter<DirectMessageListenerContainer.SimpleConsumer>

_consumers

protected readonly List<DirectMessageListenerContainer.SimpleConsumer> _consumers

Field Value

List<DirectMessageListenerContainer.SimpleConsumer>

_consumersByQueue

protected readonly Dictionary<string, List<DirectMessageListenerContainer.SimpleConsumer>> _consumersByQueue

Field Value

Dictionary<string, List<DirectMessageListenerContainer.SimpleConsumer>>

_consumersToRestart

protected readonly List<DirectMessageListenerContainer.SimpleConsumer> _consumersToRestart

Field Value

List<DirectMessageListenerContainer.SimpleConsumer>

Properties

AckTimeout

public virtual long AckTimeout { get; set; }

Property Value

long

ConsumersPerQueue

public virtual int ConsumersPerQueue { get; set; }

Property Value

int

Exclusive

public override bool Exclusive { get; set; }

Property Value

bool

LastRestartAttempt

public virtual long LastRestartAttempt { get; }

Property Value

long

MessagesPerAck

public virtual int MessagesPerAck { get; set; }

Property Value

int

MonitorInterval

public virtual long MonitorInterval { get; set; }

Property Value

long

Methods

ActualStart()

protected virtual void ActualStart()

AddQueueNames(params string[])

public override void AddQueueNames(params string[] queueNames)

Parameters

queueNames string[]

AddQueues(params IQueue[])

public override void AddQueues(params IQueue[] queues)

Parameters

queues IQueue[]

ConsumerRemoved(SimpleConsumer)

protected virtual void ConsumerRemoved(DirectMessageListenerContainer.SimpleConsumer consumer)

Parameters

consumer DirectMessageListenerContainer.SimpleConsumer

DoInitialize()

protected override void DoInitialize()

DoRedeclareElementsIfNecessary()

protected virtual void DoRedeclareElementsIfNecessary()

DoShutdown()

protected override void DoShutdown()

DoStart()

protected override void DoStart()

FindIdleConsumer()

protected virtual int FindIdleConsumer()

Returns

int

ProcessMonitorTask()

protected virtual void ProcessMonitorTask()

RemoveQueueNames(params string[])

public override bool RemoveQueueNames(params string[] queueNames)

Parameters

queueNames string[]

Returns

bool

RemoveQueues(params IQueue[])

public override void RemoveQueues(params IQueue[] queues)

Parameters

queues IQueue[]

SetQueueNames(params string[])

public override void SetQueueNames(params string[] queueNames)

Parameters

queueNames string[]