Class MessageListenerAdapter

Namespace

Steeltoe.Messaging.RabbitMQ.Listener.Adapters

Assembly

Steeltoe.Messaging.RabbitMQ.dll

public class MessageListenerAdapter : AbstractMessageListenerAdapter, IChannelAwareMessageListener, IMessageListener

Inheritance

object

AbstractMessageListenerAdapter

MessageListenerAdapter

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

AbstractMessageListenerAdapter.OnMessage(IMessage)

AbstractMessageListenerAdapter.OnMessageBatch(List<IMessage>, IModel)

AbstractMessageListenerAdapter.OnMessageBatch(List<IMessage>)

AbstractMessageListenerAdapter.BuildMessage(IModel, object, Type)

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

MessageListenerAdapter(IApplicationContext, ILogger)

public MessageListenerAdapter(IApplicationContext context, ILogger logger = null)

Parameters

context IApplicationContext

logger ILogger

MessageListenerAdapter(IApplicationContext, object, ILogger)

public MessageListenerAdapter(IApplicationContext context, object delgate, ILogger logger = null)

Parameters

context IApplicationContext

delgate object

logger ILogger

MessageListenerAdapter(IApplicationContext, object, ISmartMessageConverter, ILogger)

public MessageListenerAdapter(IApplicationContext context, object delgate, ISmartMessageConverter messageConverter, ILogger logger = null)

Parameters

context IApplicationContext

delgate object

messageConverter ISmartMessageConverter

logger ILogger

MessageListenerAdapter(IApplicationContext, object, string, ILogger)

public MessageListenerAdapter(IApplicationContext context, object delgate, string defaultListenerMethod, ILogger logger = null)

Parameters

context IApplicationContext

delgate object

defaultListenerMethod string

logger ILogger

Fields

ORIGINAL_DEFAULT_LISTENER_METHOD

public const string ORIGINAL_DEFAULT_LISTENER_METHOD = "HandleMessage"

Field Value

string

Properties

DefaultListenerMethod

public string DefaultListenerMethod { get; set; }

Property Value

string

Instance

public object Instance { get; set; }

Property Value

object

Methods

AddQueueOrTagToMethodName(string, string)

public void AddQueueOrTagToMethodName(string queueOrTag, string methodName)

Parameters

queueOrTag string

methodName string

BuildListenerArguments(object)

protected virtual object[] BuildListenerArguments(object extractedMessage)

Parameters

extractedMessage object

Returns

object[]

BuildListenerArguments(object, IModel, IMessage)

protected virtual object[] BuildListenerArguments(object extractedMessage, IModel channel, IMessage message)

Parameters

extractedMessage object

channel IModel

message IMessage

Returns

object[]

GetListenerMethodName(IMessage, object)

protected virtual string GetListenerMethodName(IMessage originalMessage, object extractedMessage)

Parameters

originalMessage IMessage

extractedMessage object

Returns

string

InvokeListenerMethod(string, object[], IMessage)

protected virtual object InvokeListenerMethod(string methodName, object[] arguments, IMessage originalMessage)

Parameters

methodName string

arguments object[]

originalMessage IMessage

Returns

object

OnMessage(IMessage, IModel)

public override void OnMessage(IMessage message, IModel channel)

Parameters

message IMessage

channel IModel

RemoveQueueOrTagToMethodName(string)

public string RemoveQueueOrTagToMethodName(string queueOrTag)

Parameters

queueOrTag string

Returns

string

SetQueueOrTagToMethodName(Dictionary<string, string>)

public void SetQueueOrTagToMethodName(Dictionary<string, string> queueOrTagToMethodName)

Parameters

queueOrTagToMethodName Dictionary<string, string>