X

Class DirectReplyToMessageListenerContainer

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 DirectReplyToMessageListenerContainer : DirectMessageListenerContainer, IMessageListenerContainer

Constructors

| Edit this page View Source

DirectReplyToMessageListenerContainer(IApplicationContext, IConnectionFactory, String, ILoggerFactory)

Declaration
public DirectReplyToMessageListenerContainer(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

DirectReplyToMessageListenerContainer(IApplicationContext, String, ILoggerFactory)

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

DirectReplyToMessageListenerContainer(String, ILoggerFactory)

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

Properties

| Edit this page View Source

ConsumersPerQueue

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

MessageListener

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

MonitorInterval

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

Methods

| Edit this page View Source

AddQueueNames(String[])

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

ConsumerRemoved(DirectMessageListenerContainer.SimpleConsumer)

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

DoStart()

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

FindIdleConsumer()

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

GetChannelHolder()

Declaration
public DirectReplyToMessageListenerContainer.ChannelHolder GetChannelHolder()
Returns
Type Description
DirectReplyToMessageListenerContainer.ChannelHolder
| Edit this page View Source

ProcessMonitorTask()

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

ReleaseConsumerFor(DirectReplyToMessageListenerContainer.ChannelHolder, Boolean, String)

Declaration
public void ReleaseConsumerFor(DirectReplyToMessageListenerContainer.ChannelHolder channelHolder, bool cancelConsumer, string message)
Parameters
Type Name Description
DirectReplyToMessageListenerContainer.ChannelHolder channelHolder
System.Boolean cancelConsumer
System.String message
| Edit this page View Source

RemoveQueueNames(String[])

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

SetQueueNames(String[])

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

Implements

ISmartLifecycle
IDisposable
IServiceNameAware