Class MessagingMessageListenerAdapter

Inheritance

System.Object

AbstractMessageListenerAdapter

MessagingMessageListenerAdapter

BatchMessagingMessageListenerAdapter

Implements

IChannelAwareMessageListener

IMessageListener

Inherited Members

AbstractMessageListenerAdapter._logger

AbstractMessageListenerAdapter.ApplicationContext

AbstractMessageListenerAdapter.Encoding

AbstractMessageListenerAdapter.ResponseRoutingKey

AbstractMessageListenerAdapter.ResponseExchange

AbstractMessageListenerAdapter.ResponseAddress

AbstractMessageListenerAdapter.MandatoryPublish

AbstractMessageListenerAdapter.MessageConverter

AbstractMessageListenerAdapter.BeforeSendReplyPostProcessors

AbstractMessageListenerAdapter.RetryTemplate

AbstractMessageListenerAdapter.RecoveryCallback

AbstractMessageListenerAdapter.DefaultRequeueRejected

AbstractMessageListenerAdapter.ContainerAckMode

AbstractMessageListenerAdapter.IsManualAck

AbstractMessageListenerAdapter.EvalContext

AbstractMessageListenerAdapter.MessagePropertiesConverter

AbstractMessageListenerAdapter.ResponseExpression

AbstractMessageListenerAdapter.ReplyPostProcessor

AbstractMessageListenerAdapter.SetResponseAddress(String)

AbstractMessageListenerAdapter.SetServiceResolver(IServiceResolver)

AbstractMessageListenerAdapter.SetBeforeSendReplyPostProcessors(IMessagePostProcessor[])

AbstractMessageListenerAdapter.OnMessage(IMessage)

AbstractMessageListenerAdapter.OnMessageBatch(List<IMessage>, RabbitMQ.Client.IModel)

AbstractMessageListenerAdapter.OnMessageBatch(List<IMessage>)

AbstractMessageListenerAdapter.HandleListenerException(Exception)

AbstractMessageListenerAdapter.ExtractMessage(IMessage)

AbstractMessageListenerAdapter.HandleResult(InvocationResult, IMessage, RabbitMQ.Client.IModel)

AbstractMessageListenerAdapter.HandleResult(InvocationResult, IMessage, RabbitMQ.Client.IModel, Object)

AbstractMessageListenerAdapter.DoHandleResult(InvocationResult, IMessage, RabbitMQ.Client.IModel, Object)

AbstractMessageListenerAdapter.GetReceivedExchange(IMessage)

AbstractMessageListenerAdapter.PostProcessResponse(IMessage, IMessage)

AbstractMessageListenerAdapter.GetReplyToAddress(IMessage, Object, InvocationResult)

AbstractMessageListenerAdapter.SendResponse(RabbitMQ.Client.IModel, Address, IMessage<Byte[]>)

AbstractMessageListenerAdapter.DoPublish(RabbitMQ.Client.IModel, Address, IMessage<Byte[]>)

AbstractMessageListenerAdapter.PostProcessChannel(RabbitMQ.Client.IModel, IMessage)

Namespace: Steeltoe.Messaging.RabbitMQ.Listener.Adapters

Assembly: Steeltoe.Messaging.RabbitMQ.dll

Syntax

public class MessagingMessageListenerAdapter : AbstractMessageListenerAdapter, IChannelAwareMessageListener, IMessageListener

Constructors

| Edit this page View Source

MessagingMessageListenerAdapter(IApplicationContext, ILogger)

Declaration

public MessagingMessageListenerAdapter(IApplicationContext context, ILogger logger = null)

Parameters

Type	Name	Description
IApplicationContext	context
ILogger	logger

| Edit this page View Source

MessagingMessageListenerAdapter(IApplicationContext, Object, MethodInfo, ILogger)

Declaration

public MessagingMessageListenerAdapter(IApplicationContext context, object instance, MethodInfo method, ILogger logger = null)

Parameters

Type	Name	Description
IApplicationContext	context
System.Object	instance
MethodInfo	method
ILogger	logger

| Edit this page View Source

MessagingMessageListenerAdapter(IApplicationContext, Object, MethodInfo, Boolean, IRabbitListenerErrorHandler, ILogger)

Declaration

public MessagingMessageListenerAdapter(IApplicationContext context, object instance, MethodInfo method, bool returnExceptions, IRabbitListenerErrorHandler errorHandler, ILogger logger = null)

Parameters

Type	Name	Description
IApplicationContext	context
System.Object	instance
MethodInfo	method
System.Boolean	returnExceptions
IRabbitListenerErrorHandler	errorHandler
ILogger	logger

| Edit this page View Source

MessagingMessageListenerAdapter(IApplicationContext, Object, MethodInfo, Boolean, IRabbitListenerErrorHandler, Boolean, ILogger)

Declaration

protected MessagingMessageListenerAdapter(IApplicationContext context, object instance, MethodInfo method, bool returnExceptions, IRabbitListenerErrorHandler errorHandler, bool batch, ILogger logger = null)

Parameters

Type	Name	Description
IApplicationContext	context
System.Object	instance
MethodInfo	method
System.Boolean	returnExceptions
IRabbitListenerErrorHandler	errorHandler
System.Boolean	batch
ILogger	logger

Properties

| Edit this page View Source

ErrorHandler

Declaration

public IRabbitListenerErrorHandler ErrorHandler { get; }

Property Value

Type	Description
IRabbitListenerErrorHandler

| Edit this page View Source

HandlerAdapter

Declaration

public HandlerAdapter HandlerAdapter { get; set; }

Property Value

Type	Description
HandlerAdapter

| Edit this page View Source

InferredArgumentType

Declaration

public Type InferredArgumentType { get; set; }

Property Value

Type	Description
Type

| Edit this page View Source

Instance

Declaration

public virtual object Instance { get; }

Property Value

Type	Description
System.Object

| Edit this page View Source

IsBatch

Declaration

public bool IsBatch { get; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

IsMessageByteArrayList

Declaration

public bool IsMessageByteArrayList { get; set; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

IsMessageList

Declaration

public bool IsMessageList { get; set; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

Method

Declaration

public virtual MethodInfo Method { get; }

Property Value

Type	Description
MethodInfo

| Edit this page View Source

ReturnExceptions

Declaration

public bool ReturnExceptions { get; }

Property Value

Type	Description
System.Boolean

Methods

| Edit this page View Source

BuildMessage(RabbitMQ.Client.IModel, Object, Type)

Declaration

protected override IMessage<byte[]> BuildMessage(RabbitMQ.Client.IModel channel, object result, Type genericType)

Parameters

Type	Name	Description
RabbitMQ.Client.IModel	channel
System.Object	result
Type	genericType

Returns

Type	Description
IMessage<System.Byte[]>

Overrides

AbstractMessageListenerAdapter.BuildMessage(RabbitMQ.Client.IModel, Object, Type)

| Edit this page View Source

InvokeHandlerAndProcessResult(IMessage, RabbitMQ.Client.IModel, IMessage)

Declaration

protected void InvokeHandlerAndProcessResult(IMessage amqpMessage, RabbitMQ.Client.IModel channel, IMessage message)

Parameters

Type	Name	Description
IMessage	amqpMessage
RabbitMQ.Client.IModel	channel
IMessage	message

| Edit this page View Source

OnMessage(IMessage, RabbitMQ.Client.IModel)

Declaration

public override void OnMessage(IMessage amqpMessage, RabbitMQ.Client.IModel channel)

Parameters

Type	Name	Description
IMessage	amqpMessage
RabbitMQ.Client.IModel	channel

Overrides

AbstractMessageListenerAdapter.OnMessage(IMessage, RabbitMQ.Client.IModel)

| Edit this page View Source

PreprocesMessage(IMessage)

Declaration

protected void PreprocesMessage(IMessage message)

Parameters

Type	Name	Description
IMessage	message

Implements

IChannelAwareMessageListener

IMessageListener