X

Class DirectMessageListenerContainer

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

Constructors

| Edit this page View Source

DirectMessageListenerContainer(IApplicationContext, IConnectionFactory, String, ILoggerFactory)

Declaration
public DirectMessageListenerContainer(IApplicationContext applicationContext, IConnectionFactory connectionFactory, string name = null, ILoggerFactory loggerFactory = null)
Parameters
Type Name Description
IApplicationContext applicationContext
IConnectionFactory connectionFactory
System.String name
ILoggerFactory loggerFactory
| Edit this page View Source

DirectMessageListenerContainer(IApplicationContext, String, ILoggerFactory)

Declaration
public DirectMessageListenerContainer(IApplicationContext applicationContext, string name = null, ILoggerFactory loggerFactory = null)
Parameters
Type Name Description
IApplicationContext applicationContext
System.String name
ILoggerFactory loggerFactory
| Edit this page View Source

DirectMessageListenerContainer(String, ILoggerFactory)

Declaration
public DirectMessageListenerContainer(string name = null, ILoggerFactory loggerFactory = null)
Parameters
Type Name Description
System.String name
ILoggerFactory loggerFactory

Fields

| Edit this page View Source

_cancellationLock

Declaration
protected readonly ActiveObjectCounter<DirectMessageListenerContainer.SimpleConsumer> _cancellationLock
Field Value
Type Description
ActiveObjectCounter<DirectMessageListenerContainer.SimpleConsumer>
| Edit this page View Source

_consumers

Declaration
protected readonly List<DirectMessageListenerContainer.SimpleConsumer> _consumers
Field Value
Type Description
List<DirectMessageListenerContainer.SimpleConsumer>
| Edit this page View Source

_consumersByQueue

Declaration
protected readonly Dictionary<string, List<DirectMessageListenerContainer.SimpleConsumer>> _consumersByQueue
Field Value
Type Description
Dictionary<System.String, List<DirectMessageListenerContainer.SimpleConsumer>>
| Edit this page View Source

_consumersToRestart

Declaration
protected readonly List<DirectMessageListenerContainer.SimpleConsumer> _consumersToRestart
Field Value
Type Description
List<DirectMessageListenerContainer.SimpleConsumer>
| Edit this page View Source

DEFAULT_ACK_TIMEOUT

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

DEFAULT_MONITOR_INTERVAL

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

START_WAIT_TIME

Declaration
protected const int START_WAIT_TIME = null
Field Value
Type Description
System.Int32

Properties

| Edit this page View Source

AckTimeout

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

ConsumersPerQueue

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

Exclusive

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

LastRestartAttempt

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

MessagesPerAck

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

MonitorInterval

Declaration
public virtual long MonitorInterval { get; set; }
Property Value
Type Description
System.Int64

Methods

| Edit this page View Source

ActualStart()

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

AddQueueNames(String[])

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

AddQueues(IQueue[])

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

ConsumerRemoved(DirectMessageListenerContainer.SimpleConsumer)

Declaration
protected virtual void ConsumerRemoved(DirectMessageListenerContainer.SimpleConsumer consumer)
Parameters
Type Name Description
DirectMessageListenerContainer.SimpleConsumer consumer
| Edit this page View Source

DoInitialize()

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

DoRedeclareElementsIfNecessary()

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

DoShutdown()

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

DoStart()

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

FindIdleConsumer()

Declaration
protected virtual int FindIdleConsumer()
Returns
Type Description
System.Int32
| Edit this page View Source

ProcessMonitorTask()

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

RemoveQueueNames(String[])

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

RemoveQueues(IQueue[])

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

SetQueueNames(String[])

Declaration
public override void SetQueueNames(params string[] queueNames)
Parameters
Type Name Description
System.String[] queueNames
Overrides

Implements

ISmartLifecycle
IDisposable
IServiceNameAware