Class AbstractRabbitListenerEndpoint
public abstract class AbstractRabbitListenerEndpoint : IRabbitListenerEndpoint
- Inheritance
-
AbstractRabbitListenerEndpoint
- Implements
- Derived
- Inherited Members
Constructors
AbstractRabbitListenerEndpoint(IApplicationContext, ILoggerFactory)
protected AbstractRabbitListenerEndpoint(IApplicationContext applicationContext, ILoggerFactory loggerFactory = null)
Parameters
applicationContext
IApplicationContextloggerFactory
ILoggerFactory
Fields
_logger
protected readonly ILogger _logger
Field Value
_loggerFactory
protected readonly ILoggerFactory _loggerFactory
Field Value
Properties
AckMode
public AcknowledgeMode? AckMode { get; set; }
Property Value
Admin
public IRabbitAdmin Admin { get; set; }
Property Value
ApplicationContext
public IApplicationContext ApplicationContext { get; set; }
Property Value
AutoStartup
public bool? AutoStartup { get; set; }
Property Value
- bool?
BatchListener
public bool BatchListener { get; set; }
Property Value
BatchingStrategy
public IBatchingStrategy BatchingStrategy { get; set; }
Property Value
Concurrency
public int? Concurrency { get; set; }
Property Value
- int?
Exclusive
public bool Exclusive { get; set; }
Property Value
ExpressionContext
protected IServiceExpressionContext ExpressionContext { get; set; }
Property Value
Group
public string Group { get; set; }
Property Value
Id
public string Id { get; set; }
Property Value
MessageConverter
public ISmartMessageConverter MessageConverter { get; set; }
Property Value
Priority
public int? Priority { get; set; }
Property Value
- int?
QueueNames
public List<string> QueueNames { get; }
Property Value
Queues
public List<IQueue> Queues { get; }
Property Value
ReplyPostProcessor
public IReplyPostProcessor ReplyPostProcessor { get; set; }
Property Value
Resolver
protected IServiceExpressionResolver Resolver { get; set; }
Property Value
ServiceResolver
protected IServiceResolver ServiceResolver { get; set; }
Property Value
Methods
CreateMessageListener(IMessageListenerContainer)
protected abstract IMessageListener CreateMessageListener(IMessageListenerContainer container)
Parameters
container
IMessageListenerContainer
Returns
GetEndpointDescription()
protected virtual StringBuilder GetEndpointDescription()
Returns
SetQueueNames(params string[])
public void SetQueueNames(params string[] queueNames)
Parameters
queueNames
string[]
SetQueues(params IQueue[])
public void SetQueues(params IQueue[] queues)
Parameters
queues
IQueue[]
SetupListenerContainer(IMessageListenerContainer)
public void SetupListenerContainer(IMessageListenerContainer listenerContainer)
Parameters
listenerContainer
IMessageListenerContainer
ToString()
Returns a string that represents the current object.
public override string ToString()
Returns
- string
A string that represents the current object.