Class AbstractMessageListenerAdapter

Namespace

Steeltoe.Messaging.RabbitMQ.Listener.Adapters

Assembly

Steeltoe.Messaging.RabbitMQ.dll

public abstract class AbstractMessageListenerAdapter : IChannelAwareMessageListener, IMessageListener

Inheritance

object

AbstractMessageListenerAdapter

Implements

IChannelAwareMessageListener

IMessageListener

Derived

MessageListenerAdapter

MessagingMessageListenerAdapter

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

AbstractMessageListenerAdapter(IApplicationContext, ILogger)

protected AbstractMessageListenerAdapter(IApplicationContext context, ILogger logger = null)

Parameters

context IApplicationContext

logger ILogger

Fields

_logger

protected readonly ILogger _logger

Field Value

ILogger

Properties

ApplicationContext

public IApplicationContext ApplicationContext { get; set; }

Property Value

IApplicationContext

BeforeSendReplyPostProcessors

public virtual List<IMessagePostProcessor> BeforeSendReplyPostProcessors { get; }

Property Value

List<IMessagePostProcessor>

ContainerAckMode

public virtual AcknowledgeMode ContainerAckMode { get; set; }

Property Value

AcknowledgeMode

DefaultRequeueRejected

public virtual bool DefaultRequeueRejected { get; set; }

Property Value

bool

Encoding

public virtual string Encoding { get; set; }

Property Value

string

EvalContext

public virtual StandardEvaluationContext EvalContext { get; set; }

Property Value

StandardEvaluationContext

IsManualAck

public virtual bool IsManualAck { get; }

Property Value

bool

MandatoryPublish

public virtual bool MandatoryPublish { get; set; }

Property Value

bool

MessageConverter

public virtual ISmartMessageConverter MessageConverter { get; set; }

Property Value

ISmartMessageConverter

MessagePropertiesConverter

public virtual IMessageHeadersConverter MessagePropertiesConverter { get; set; }

Property Value

IMessageHeadersConverter

RecoveryCallback

public virtual IRecoveryCallback RecoveryCallback { get; set; }

Property Value

IRecoveryCallback

ReplyPostProcessor

public virtual IReplyPostProcessor ReplyPostProcessor { get; set; }

Property Value

IReplyPostProcessor

ResponseAddress

public virtual Address ResponseAddress { get; set; }

Property Value

Address

ResponseExchange

public virtual string ResponseExchange { get; set; }

Property Value

string

ResponseExpression

public virtual IExpression ResponseExpression { get; set; }

Property Value

IExpression

ResponseRoutingKey

public virtual string ResponseRoutingKey { get; set; }

Property Value

string

RetryTemplate

public virtual RetryTemplate RetryTemplate { get; set; }

Property Value

RetryTemplate

Methods

BuildMessage(IModel, object, Type)

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

Parameters

channel IModel

result object

genericType Type

Returns

IMessage<byte[]>

DoHandleResult(InvocationResult, IMessage, IModel, object)

protected virtual void DoHandleResult(InvocationResult resultArg, IMessage request, IModel channel, object source)

Parameters

resultArg InvocationResult

request IMessage

channel IModel

source object

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

protected virtual void DoPublish(IModel channel, Address replyTo, IMessage<byte[]> message)

Parameters

channel IModel

replyTo Address

message IMessage<byte[]>

ExtractMessage(IMessage)

protected virtual object ExtractMessage(IMessage message)

Parameters

message IMessage

Returns

object

GetReceivedExchange(IMessage)

protected virtual string GetReceivedExchange(IMessage request)

Parameters

request IMessage

Returns

string

GetReplyToAddress(IMessage, object, InvocationResult)

protected virtual Address GetReplyToAddress(IMessage request, object source, InvocationResult result)

Parameters

request IMessage

source object

result InvocationResult

Returns

Address

HandleListenerException(Exception)

protected virtual void HandleListenerException(Exception exception)

Parameters

exception Exception

HandleResult(InvocationResult, IMessage, IModel)

protected virtual void HandleResult(InvocationResult resultArg, IMessage request, IModel channel)

Parameters

resultArg InvocationResult

request IMessage

channel IModel

HandleResult(InvocationResult, IMessage, IModel, object)

protected virtual void HandleResult(InvocationResult resultArg, IMessage request, IModel channel, object source)

Parameters

resultArg InvocationResult

request IMessage

channel IModel

source object

OnMessage(IMessage)

public virtual void OnMessage(IMessage message)

Parameters

message IMessage

OnMessage(IMessage, IModel)

public abstract void OnMessage(IMessage message, IModel channel)

Parameters

message IMessage

channel IModel

OnMessageBatch(List<IMessage>)

public virtual void OnMessageBatch(List<IMessage> messages)

Parameters

messages List<IMessage>

OnMessageBatch(List<IMessage>, IModel)

public virtual void OnMessageBatch(List<IMessage> messages, IModel channel)

Parameters

messages List<IMessage>

channel IModel

PostProcessChannel(IModel, IMessage)

protected virtual void PostProcessChannel(IModel channel, IMessage response)

Parameters

channel IModel

response IMessage

PostProcessResponse(IMessage, IMessage)

protected virtual void PostProcessResponse(IMessage request, IMessage response)

Parameters

request IMessage

response IMessage

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

protected void SendResponse(IModel channel, Address replyTo, IMessage<byte[]> messageIn)

Parameters

channel IModel

replyTo Address

messageIn IMessage<byte[]>

SetBeforeSendReplyPostProcessors(params IMessagePostProcessor[])

public virtual void SetBeforeSendReplyPostProcessors(params IMessagePostProcessor[] beforeSendReplyPostProcessors)

Parameters

beforeSendReplyPostProcessors IMessagePostProcessor[]

SetResponseAddress(string)

public virtual void SetResponseAddress(string defaultReplyTo)

Parameters

defaultReplyTo string

SetServiceResolver(IServiceResolver)

public void SetServiceResolver(IServiceResolver serviceResolver)

Parameters

serviceResolver IServiceResolver