Class MessagingMessageListenerAdapter

Namespace

Steeltoe.Messaging.RabbitMQ.Listener.Adapters

Assembly

Steeltoe.Messaging.RabbitMQ.dll

[Obsolete("This feature will be removed in the next major version. See https://steeltoe.io/docs/v3/obsolete for details.")]
public class MessagingMessageListenerAdapter : AbstractMessageListenerAdapter, IChannelAwareMessageListener, IMessageListener

Inheritance

object

AbstractMessageListenerAdapter

MessagingMessageListenerAdapter

Implements

IChannelAwareMessageListener

IMessageListener

Derived

BatchMessagingMessageListenerAdapter

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(params IMessagePostProcessor[])

AbstractMessageListenerAdapter.OnMessage(IMessage)

AbstractMessageListenerAdapter.OnMessageBatch(List<IMessage>, IModel)

AbstractMessageListenerAdapter.OnMessageBatch(List<IMessage>)

AbstractMessageListenerAdapter.HandleListenerException(Exception)

AbstractMessageListenerAdapter.ExtractMessage(IMessage)

AbstractMessageListenerAdapter.HandleResult(InvocationResult, IMessage, IModel)

AbstractMessageListenerAdapter.HandleResult(InvocationResult, IMessage, IModel, object)

AbstractMessageListenerAdapter.DoHandleResult(InvocationResult, IMessage, IModel, object)

AbstractMessageListenerAdapter.GetReceivedExchange(IMessage)

AbstractMessageListenerAdapter.PostProcessResponse(IMessage, IMessage)

AbstractMessageListenerAdapter.GetReplyToAddress(IMessage, object, InvocationResult)

AbstractMessageListenerAdapter.SendResponse(IModel, Address, IMessage<byte[]>)

AbstractMessageListenerAdapter.DoPublish(IModel, Address, IMessage<byte[]>)

AbstractMessageListenerAdapter.PostProcessChannel(IModel, IMessage)

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

MessagingMessageListenerAdapter(IApplicationContext, ILogger)

public MessagingMessageListenerAdapter(IApplicationContext context, ILogger logger = null)

Parameters

context IApplicationContext

logger ILogger

MessagingMessageListenerAdapter(IApplicationContext, object, MethodInfo, ILogger)

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

Parameters

context IApplicationContext

instance object

method MethodInfo

logger ILogger

MessagingMessageListenerAdapter(IApplicationContext, object, MethodInfo, bool, IRabbitListenerErrorHandler, ILogger)

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

Parameters

context IApplicationContext

instance object

method MethodInfo

returnExceptions bool

errorHandler IRabbitListenerErrorHandler

logger ILogger

MessagingMessageListenerAdapter(IApplicationContext, object, MethodInfo, bool, IRabbitListenerErrorHandler, bool, ILogger)

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

Parameters

context IApplicationContext

instance object

method MethodInfo

returnExceptions bool

errorHandler IRabbitListenerErrorHandler

batch bool

logger ILogger

Properties

ErrorHandler

public IRabbitListenerErrorHandler ErrorHandler { get; }

Property Value

IRabbitListenerErrorHandler

HandlerAdapter

public HandlerAdapter HandlerAdapter { get; set; }

Property Value

HandlerAdapter

InferredArgumentType

public Type InferredArgumentType { get; set; }

Property Value

Type

Instance

public virtual object Instance { get; }

Property Value

object

IsBatch

public bool IsBatch { get; }

Property Value

bool

IsMessageByteArrayList

public bool IsMessageByteArrayList { get; set; }

Property Value

bool

IsMessageList

public bool IsMessageList { get; set; }

Property Value

bool

Method

public virtual MethodInfo Method { get; }

Property Value

MethodInfo

ReturnExceptions

public bool ReturnExceptions { get; }

Property Value

bool

Methods

BuildMessage(IModel, object, Type)

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

Parameters

channel IModel

result object

genericType Type

Returns

IMessage<byte[]>

InvokeHandlerAndProcessResult(IMessage, IModel, IMessage)

protected void InvokeHandlerAndProcessResult(IMessage amqpMessage, IModel channel, IMessage message)

Parameters

amqpMessage IMessage

channel IModel

message IMessage

OnMessage(IMessage, IModel)

public override void OnMessage(IMessage amqpMessage, IModel channel)

Parameters

amqpMessage IMessage

channel IModel

PreprocesMessage(IMessage)

protected void PreprocesMessage(IMessage message)

Parameters

message IMessage