Table of Contents

Class AbstractRabbitListenerEndpoint

Namespace
Steeltoe.Messaging.RabbitMQ.Listener
Assembly
Steeltoe.Messaging.RabbitMQ.dll
public abstract class AbstractRabbitListenerEndpoint : IRabbitListenerEndpoint
Inheritance
AbstractRabbitListenerEndpoint
Implements
Derived
Inherited Members

Constructors

AbstractRabbitListenerEndpoint(IApplicationContext, ILoggerFactory)

protected AbstractRabbitListenerEndpoint(IApplicationContext applicationContext, ILoggerFactory loggerFactory = null)

Parameters

applicationContext IApplicationContext
loggerFactory ILoggerFactory

Fields

_logger

protected readonly ILogger _logger

Field Value

ILogger

_loggerFactory

protected readonly ILoggerFactory _loggerFactory

Field Value

ILoggerFactory

Properties

AckMode

public AcknowledgeMode? AckMode { get; set; }

Property Value

AcknowledgeMode?

Admin

public IRabbitAdmin Admin { get; set; }

Property Value

IRabbitAdmin

ApplicationContext

public IApplicationContext ApplicationContext { get; set; }

Property Value

IApplicationContext

AutoStartup

public bool? AutoStartup { get; set; }

Property Value

bool?

BatchListener

public bool BatchListener { get; set; }

Property Value

bool

BatchingStrategy

public IBatchingStrategy BatchingStrategy { get; set; }

Property Value

IBatchingStrategy

Concurrency

public int? Concurrency { get; set; }

Property Value

int?

Exclusive

public bool Exclusive { get; set; }

Property Value

bool

ExpressionContext

protected IServiceExpressionContext ExpressionContext { get; set; }

Property Value

IServiceExpressionContext

Group

public string Group { get; set; }

Property Value

string

Id

public string Id { get; set; }

Property Value

string

MessageConverter

public ISmartMessageConverter MessageConverter { get; set; }

Property Value

ISmartMessageConverter

Priority

public int? Priority { get; set; }

Property Value

int?

QueueNames

public List<string> QueueNames { get; }

Property Value

List<string>

Queues

public List<IQueue> Queues { get; }

Property Value

List<IQueue>

ReplyPostProcessor

public IReplyPostProcessor ReplyPostProcessor { get; set; }

Property Value

IReplyPostProcessor

Resolver

protected IServiceExpressionResolver Resolver { get; set; }

Property Value

IServiceExpressionResolver

ServiceResolver

protected IServiceResolver ServiceResolver { get; set; }

Property Value

IServiceResolver

Methods

CreateMessageListener(IMessageListenerContainer)

protected abstract IMessageListener CreateMessageListener(IMessageListenerContainer container)

Parameters

container IMessageListenerContainer

Returns

IMessageListener

GetEndpointDescription()

protected virtual StringBuilder GetEndpointDescription()

Returns

StringBuilder

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.