Class DirectReplyToMessageListenerContainer

Namespace

Steeltoe.Messaging.RabbitMQ.Listener

Assembly

Steeltoe.Messaging.RabbitMQ.dll

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

Inheritance

object

AbstractMessageListenerContainer

DirectMessageListenerContainer

DirectReplyToMessageListenerContainer

Implements

IMessageListenerContainer

ISmartLifecycle

ILifecycle

IPhased

IDisposable

IServiceNameAware

Inherited Members

DirectMessageListenerContainer._consumers

DirectMessageListenerContainer._consumersByQueue

DirectMessageListenerContainer._cancellationLock

DirectMessageListenerContainer._consumersToRestart

DirectMessageListenerContainer.START_WAIT_TIME

DirectMessageListenerContainer.DEFAULT_MONITOR_INTERVAL

DirectMessageListenerContainer.DEFAULT_ACK_TIMEOUT

DirectMessageListenerContainer.Exclusive

DirectMessageListenerContainer.MessagesPerAck

DirectMessageListenerContainer.AckTimeout

DirectMessageListenerContainer.LastRestartAttempt

DirectMessageListenerContainer.AddQueues(params IQueue[])

DirectMessageListenerContainer.RemoveQueues(params IQueue[])

DirectMessageListenerContainer.DoInitialize()

DirectMessageListenerContainer.ActualStart()

DirectMessageListenerContainer.DoRedeclareElementsIfNecessary()

DirectMessageListenerContainer.DoShutdown()

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.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

DirectReplyToMessageListenerContainer(IApplicationContext, IConnectionFactory, string, ILoggerFactory)

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

Parameters

applicationContext IApplicationContext

connectionFactory IConnectionFactory

name string

loggerFactory ILoggerFactory

DirectReplyToMessageListenerContainer(IApplicationContext, string, ILoggerFactory)

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

Parameters

applicationContext IApplicationContext

name string

loggerFactory ILoggerFactory

DirectReplyToMessageListenerContainer(string, ILoggerFactory)

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

Parameters

name string

loggerFactory ILoggerFactory

Properties

ConsumersPerQueue

public override int ConsumersPerQueue { get; set; }

Property Value

int

MessageListener

public override IMessageListener MessageListener { get; set; }

Property Value

IMessageListener

MonitorInterval

public override long MonitorInterval { get; set; }

Property Value

long

Methods

AddQueueNames(params string[])

public override void AddQueueNames(params string[] queueName)

Parameters

queueName string[]

ConsumerRemoved(SimpleConsumer)

protected override void ConsumerRemoved(DirectMessageListenerContainer.SimpleConsumer consumer)

Parameters

consumer DirectMessageListenerContainer.SimpleConsumer

DoStart()

protected override void DoStart()

FindIdleConsumer()

protected override int FindIdleConsumer()

Returns

int

GetChannelHolder()

public DirectReplyToMessageListenerContainer.ChannelHolder GetChannelHolder()

Returns

DirectReplyToMessageListenerContainer.ChannelHolder

ProcessMonitorTask()

protected override void ProcessMonitorTask()

ReleaseConsumerFor(ChannelHolder, bool, string)

public void ReleaseConsumerFor(DirectReplyToMessageListenerContainer.ChannelHolder channelHolder, bool cancelConsumer, string message)

Parameters

channelHolder DirectReplyToMessageListenerContainer.ChannelHolder

cancelConsumer bool

message string

RemoveQueueNames(params string[])

public override bool RemoveQueueNames(params string[] queueName)

Parameters

queueName string[]

Returns

bool

SetQueueNames(params string[])

public override void SetQueueNames(params string[] queueName)

Parameters

queueName string[]