Table of Contents

Class RabbitListenerAttributeProcessor

Namespace
Steeltoe.Messaging.RabbitMQ.Config
Assembly
Steeltoe.Messaging.RabbitMQ.dll
public class RabbitListenerAttributeProcessor : IRabbitListenerAttributeProcessor, IServiceNameAware, IOrdered
Inheritance
RabbitListenerAttributeProcessor
Implements
Inherited Members

Constructors

RabbitListenerAttributeProcessor(IApplicationContext, IRabbitListenerEndpointRegistry, IRabbitListenerEndpointRegistrar, IMessageHandlerMethodFactory, IEnumerable<RabbitListenerMetadata>, ILoggerFactory)

public RabbitListenerAttributeProcessor(IApplicationContext applicationContext, IRabbitListenerEndpointRegistry endpointRegistry, IRabbitListenerEndpointRegistrar registrar, IMessageHandlerMethodFactory messageHandlerMethodFactory, IEnumerable<RabbitListenerMetadata> rabbitListeners, ILoggerFactory loggerFactory = null)

Parameters

applicationContext IApplicationContext
endpointRegistry IRabbitListenerEndpointRegistry
registrar IRabbitListenerEndpointRegistrar
messageHandlerMethodFactory IMessageHandlerMethodFactory
rabbitListeners IEnumerable<RabbitListenerMetadata>
loggerFactory ILoggerFactory

Fields

DEFAULT_SERVICE_NAME

public const string DEFAULT_SERVICE_NAME = "RabbitListenerAttributeProcessor"

Field Value

string

Properties

ApplicationContext

public IApplicationContext ApplicationContext { get; set; }

Property Value

IApplicationContext

Charset

public Encoding Charset { get; set; }

Property Value

Encoding

ContainerFactoryServiceName

public string ContainerFactoryServiceName { get; set; }

Property Value

string

EndpointRegistry

public IRabbitListenerEndpointRegistry EndpointRegistry { get; }

Property Value

IRabbitListenerEndpointRegistry

ExpressionContext

public IServiceExpressionContext ExpressionContext { get; set; }

Property Value

IServiceExpressionContext

Order

Gets the order of this object

public int Order { get; }

Property Value

int

Registrar

public IRabbitListenerEndpointRegistrar Registrar { get; }

Property Value

IRabbitListenerEndpointRegistrar

Resolver

public IServiceExpressionResolver Resolver { get; set; }

Property Value

IServiceExpressionResolver

ServiceName

public string ServiceName { get; set; }

Property Value

string

ServiceResolver

public IServiceResolver ServiceResolver { get; set; }

Property Value

IServiceResolver

Methods

Initialize()

public void Initialize()

ProcessListener(MethodRabbitListenerEndpoint, RabbitListenerAttribute, object, object, string)

protected void ProcessListener(MethodRabbitListenerEndpoint endpoint, RabbitListenerAttribute rabbitListener, object bean, object target, string beanName)

Parameters

endpoint MethodRabbitListenerEndpoint
rabbitListener RabbitListenerAttribute
bean object
target object
beanName string

ProcessMultiMethodListeners(List<RabbitListenerAttribute>, List<MethodInfo>, object, string)

protected void ProcessMultiMethodListeners(List<RabbitListenerAttribute> classLevelListeners, List<MethodInfo> multiMethods, object bean, string beanName)

Parameters

classLevelListeners List<RabbitListenerAttribute>
multiMethods List<MethodInfo>
bean object
beanName string