Class DirectRabbitListenerContainerFactory
public class DirectRabbitListenerContainerFactory : AbstractRabbitListenerContainerFactory<DirectMessageListenerContainer>, IRabbitListenerContainerFactory<DirectMessageListenerContainer>, IRabbitListenerContainerFactory, IServiceNameAware
- Inheritance
-
DirectRabbitListenerContainerFactory
- Implements
- Inherited Members
Constructors
DirectRabbitListenerContainerFactory(IApplicationContext, ILoggerFactory)
public DirectRabbitListenerContainerFactory(IApplicationContext applicationContext, ILoggerFactory loggerFactory = null)
Parameters
applicationContext
IApplicationContextloggerFactory
ILoggerFactory
DirectRabbitListenerContainerFactory(IApplicationContext, IOptionsMonitor<RabbitOptions>, IConnectionFactory, ILoggerFactory)
[ActivatorUtilitiesConstructor]
public DirectRabbitListenerContainerFactory(IApplicationContext applicationContext, IOptionsMonitor<RabbitOptions> optionsMonitor, IConnectionFactory connectionFactory, ILoggerFactory loggerFactory = null)
Parameters
applicationContext
IApplicationContextoptionsMonitor
IOptionsMonitor<RabbitOptions>connectionFactory
IConnectionFactoryloggerFactory
ILoggerFactory
DirectRabbitListenerContainerFactory(IApplicationContext, IConnectionFactory, ILoggerFactory)
public DirectRabbitListenerContainerFactory(IApplicationContext applicationContext, IConnectionFactory connectionFactory, ILoggerFactory loggerFactory = null)
Parameters
applicationContext
IApplicationContextconnectionFactory
IConnectionFactoryloggerFactory
ILoggerFactory
Fields
DEFAULT_SERVICE_NAME
public const string DEFAULT_SERVICE_NAME = "rabbitListenerContainerFactory"
Field Value
Properties
AckTimeout
public int? AckTimeout { get; set; }
Property Value
- int?
ConsumersPerQueue
public int? ConsumersPerQueue { get; set; }
Property Value
- int?
MessagesPerAck
public int? MessagesPerAck { get; set; }
Property Value
- int?
MonitorInterval
public int? MonitorInterval { get; set; }
Property Value
- int?
Methods
CreateContainerInstance()
protected override DirectMessageListenerContainer CreateContainerInstance()
Returns
InitializeContainer(DirectMessageListenerContainer, IRabbitListenerEndpoint)
protected override void InitializeContainer(DirectMessageListenerContainer instance, IRabbitListenerEndpoint endpoint)
Parameters
instance
DirectMessageListenerContainerendpoint
IRabbitListenerEndpoint