Class MessageListenerAdapter

Inheritance

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

AbstractMessageListenerAdapter.OnMessage(IMessage)

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

AbstractMessageListenerAdapter.OnMessageBatch(List<IMessage>)

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

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 MessageListenerAdapter : AbstractMessageListenerAdapter, IChannelAwareMessageListener, IMessageListener

Constructors

| Edit this page View Source

MessageListenerAdapter(IApplicationContext, ILogger)

Declaration

public MessageListenerAdapter(IApplicationContext context, ILogger logger = null)

Parameters

Type	Name	Description
IApplicationContext	context
ILogger	logger

| Edit this page View Source

MessageListenerAdapter(IApplicationContext, Object, ILogger)

Declaration

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

Parameters

Type	Name	Description
IApplicationContext	context
System.Object	delgate
ILogger	logger

| Edit this page View Source

MessageListenerAdapter(IApplicationContext, Object, ISmartMessageConverter, ILogger)

Declaration

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

Parameters

Type	Name	Description
IApplicationContext	context
System.Object	delgate
ISmartMessageConverter	messageConverter
ILogger	logger

| Edit this page View Source

MessageListenerAdapter(IApplicationContext, Object, String, ILogger)

Declaration

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

Parameters

Type	Name	Description
IApplicationContext	context
System.Object	delgate
System.String	defaultListenerMethod
ILogger	logger

Fields

| Edit this page View Source

ORIGINAL_DEFAULT_LISTENER_METHOD

Declaration

public const string ORIGINAL_DEFAULT_LISTENER_METHOD = null

Field Value

Type	Description
System.String

Properties

| Edit this page View Source

DefaultListenerMethod

Declaration

public string DefaultListenerMethod { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

Instance

Declaration

public object Instance { get; set; }

Property Value

Type	Description
System.Object

Methods

| Edit this page View Source

AddQueueOrTagToMethodName(String, String)

Declaration

public void AddQueueOrTagToMethodName(string queueOrTag, string methodName)

Parameters

Type	Name	Description
System.String	queueOrTag
System.String	methodName

| Edit this page View Source

BuildListenerArguments(Object)

Declaration

protected virtual object[] BuildListenerArguments(object extractedMessage)

Parameters

Type	Name	Description
System.Object	extractedMessage

Returns

Type	Description
System.Object[]

| Edit this page View Source

BuildListenerArguments(Object, RabbitMQ.Client.IModel, IMessage)

Declaration

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

Parameters

Type	Name	Description
System.Object	extractedMessage
RabbitMQ.Client.IModel	channel
IMessage	message

Returns

Type	Description
System.Object[]

| Edit this page View Source

GetListenerMethodName(IMessage, Object)

Declaration

protected virtual string GetListenerMethodName(IMessage originalMessage, object extractedMessage)

Parameters

Type	Name	Description
IMessage	originalMessage
System.Object	extractedMessage

Returns

Type	Description
System.String

| Edit this page View Source

InvokeListenerMethod(String, Object[], IMessage)

Declaration

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

Parameters

Type	Name	Description
System.String	methodName
System.Object[]	arguments
IMessage	originalMessage

Returns

Type	Description
System.Object

| Edit this page View Source

OnMessage(IMessage, RabbitMQ.Client.IModel)

Declaration

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

Parameters

Type	Name	Description
IMessage	message
RabbitMQ.Client.IModel	channel

Overrides

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

| Edit this page View Source

RemoveQueueOrTagToMethodName(String)

Declaration

public string RemoveQueueOrTagToMethodName(string queueOrTag)

Parameters

Type	Name	Description
System.String	queueOrTag

Returns

Type	Description
System.String

| Edit this page View Source

SetQueueOrTagToMethodName(Dictionary<String, String>)

Declaration

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

Parameters

Type	Name	Description
Dictionary<System.String, System.String>	queueOrTagToMethodName

Implements

IChannelAwareMessageListener

IMessageListener