Class AbstractMessageListenerAdapter

Inheritance

System.Object

AbstractMessageListenerAdapter

MessageListenerAdapter

MessagingMessageListenerAdapter

Implements

IChannelAwareMessageListener

IMessageListener

Namespace: Steeltoe.Messaging.RabbitMQ.Listener.Adapters

Assembly: Steeltoe.Messaging.RabbitMQ.dll

Syntax

public abstract class AbstractMessageListenerAdapter : object, IChannelAwareMessageListener, IMessageListener

Constructors

| Edit this page View Source

AbstractMessageListenerAdapter(IApplicationContext, ILogger)

Declaration

protected AbstractMessageListenerAdapter(IApplicationContext context, ILogger logger = null)

Parameters

Type	Name	Description
IApplicationContext	context
ILogger	logger

Fields

| Edit this page View Source

_logger

Declaration

protected readonly ILogger _logger

Field Value

Type	Description
ILogger

Properties

| Edit this page View Source

ApplicationContext

Declaration

public IApplicationContext ApplicationContext { get; set; }

Property Value

Type	Description
IApplicationContext

| Edit this page View Source

BeforeSendReplyPostProcessors

Declaration

public virtual List<IMessagePostProcessor> BeforeSendReplyPostProcessors { get; }

Property Value

Type	Description
List<IMessagePostProcessor>

| Edit this page View Source

ContainerAckMode

Declaration

public virtual AcknowledgeMode ContainerAckMode { get; set; }

Property Value

Type	Description
AcknowledgeMode

| Edit this page View Source

DefaultRequeueRejected

Declaration

public virtual bool DefaultRequeueRejected { get; set; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

Encoding

Declaration

public virtual string Encoding { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

EvalContext

Declaration

public virtual StandardEvaluationContext EvalContext { get; set; }

Property Value

Type	Description
StandardEvaluationContext

| Edit this page View Source

IsManualAck

Declaration

public virtual bool IsManualAck { get; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

MandatoryPublish

Declaration

public virtual bool MandatoryPublish { get; set; }

Property Value

Type	Description
System.Boolean

| Edit this page View Source

MessageConverter

Declaration

public virtual ISmartMessageConverter MessageConverter { get; set; }

Property Value

Type	Description
ISmartMessageConverter

| Edit this page View Source

MessagePropertiesConverter

Declaration

public virtual IMessageHeadersConverter MessagePropertiesConverter { get; set; }

Property Value

Type	Description
IMessageHeadersConverter

| Edit this page View Source

RecoveryCallback

Declaration

public virtual IRecoveryCallback RecoveryCallback { get; set; }

Property Value

Type	Description
IRecoveryCallback

| Edit this page View Source

ReplyPostProcessor

Declaration

public virtual IReplyPostProcessor ReplyPostProcessor { get; set; }

Property Value

Type	Description
IReplyPostProcessor

| Edit this page View Source

ResponseAddress

Declaration

public virtual Address ResponseAddress { get; set; }

Property Value

Type	Description
Address

| Edit this page View Source

ResponseExchange

Declaration

public virtual string ResponseExchange { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

ResponseExpression

Declaration

public virtual IExpression ResponseExpression { get; set; }

Property Value

Type	Description
IExpression

| Edit this page View Source

ResponseRoutingKey

Declaration

public virtual string ResponseRoutingKey { get; set; }

Property Value

Type	Description
System.String

| Edit this page View Source

RetryTemplate

Declaration

public virtual RetryTemplate RetryTemplate { get; set; }

Property Value

Type	Description
RetryTemplate

Methods

| Edit this page View Source

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

Declaration

protected virtual 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[]>

| Edit this page View Source

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

Declaration

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

Parameters

Type	Name	Description
InvocationResult	resultArg
IMessage	request
RabbitMQ.Client.IModel	channel
System.Object	source

| Edit this page View Source

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

Declaration

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

Parameters

Type	Name	Description
RabbitMQ.Client.IModel	channel
Address	replyTo
IMessage<System.Byte[]>	message

| Edit this page View Source

ExtractMessage(IMessage)

Declaration

protected virtual object ExtractMessage(IMessage message)

Parameters

Type	Name	Description
IMessage	message

Returns

Type	Description
System.Object

| Edit this page View Source

GetReceivedExchange(IMessage)

Declaration

protected virtual string GetReceivedExchange(IMessage request)

Parameters

Type	Name	Description
IMessage	request

Returns

Type	Description
System.String

| Edit this page View Source

GetReplyToAddress(IMessage, Object, InvocationResult)

Declaration

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

Parameters

Type	Name	Description
IMessage	request
System.Object	source
InvocationResult	result

Returns

Type	Description
Address

| Edit this page View Source

HandleListenerException(Exception)

Declaration

protected virtual void HandleListenerException(Exception exception)

Parameters

Type	Name	Description
Exception	exception

| Edit this page View Source

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

Declaration

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

Parameters

Type	Name	Description
InvocationResult	resultArg
IMessage	request
RabbitMQ.Client.IModel	channel

| Edit this page View Source

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

Declaration

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

Parameters

Type	Name	Description
InvocationResult	resultArg
IMessage	request
RabbitMQ.Client.IModel	channel
System.Object	source

| Edit this page View Source

OnMessage(IMessage)

Declaration

public virtual void OnMessage(IMessage message)

Parameters

Type	Name	Description
IMessage	message

| Edit this page View Source

OnMessage(IMessage, RabbitMQ.Client.IModel)

Declaration

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

Parameters

Type	Name	Description
IMessage	message
RabbitMQ.Client.IModel	channel

| Edit this page View Source

OnMessageBatch(List<IMessage>)

Declaration

public virtual void OnMessageBatch(List<IMessage> messages)

Parameters

Type	Name	Description
List<IMessage>	messages

| Edit this page View Source

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

Declaration

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

Parameters

Type	Name	Description
List<IMessage>	messages
RabbitMQ.Client.IModel	channel

| Edit this page View Source

PostProcessChannel(RabbitMQ.Client.IModel, IMessage)

Declaration

protected virtual void PostProcessChannel(RabbitMQ.Client.IModel channel, IMessage response)

Parameters

Type	Name	Description
RabbitMQ.Client.IModel	channel
IMessage	response

| Edit this page View Source

PostProcessResponse(IMessage, IMessage)

Declaration

protected virtual void PostProcessResponse(IMessage request, IMessage response)

Parameters

Type	Name	Description
IMessage	request
IMessage	response

| Edit this page View Source

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

Declaration

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

Parameters

Type	Name	Description
RabbitMQ.Client.IModel	channel
Address	replyTo
IMessage<System.Byte[]>	messageIn

| Edit this page View Source

SetBeforeSendReplyPostProcessors(IMessagePostProcessor[])

Declaration

public virtual void SetBeforeSendReplyPostProcessors(params IMessagePostProcessor[] beforeSendReplyPostProcessors)

Parameters

Type	Name	Description
IMessagePostProcessor[]	beforeSendReplyPostProcessors

| Edit this page View Source

SetResponseAddress(String)

Declaration

public virtual void SetResponseAddress(string defaultReplyTo)

Parameters

Type	Name	Description
System.String	defaultReplyTo

| Edit this page View Source

SetServiceResolver(IServiceResolver)

Declaration

public void SetServiceResolver(IServiceResolver serviceResolver)

Parameters

Type	Name	Description
IServiceResolver	serviceResolver

Implements

IChannelAwareMessageListener

IMessageListener