Class RabbitExpressionEvaluatingInterceptor

Namespace

Steeltoe.Stream.Binder.Rabbit

Assembly

Steeltoe.Stream.Binder.RabbitMQ.dll

public class RabbitExpressionEvaluatingInterceptor : IChannelInterceptor, IOrdered

Inheritance

object

RabbitExpressionEvaluatingInterceptor

Implements

IChannelInterceptor

IOrdered

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

RabbitExpressionEvaluatingInterceptor(IExpression, IExpression, IEvaluationContext)

public RabbitExpressionEvaluatingInterceptor(IExpression routingKeyExpression, IExpression delayExpression, IEvaluationContext evaluationContext)

Parameters

routingKeyExpression IExpression

delayExpression IExpression

evaluationContext IEvaluationContext

Fields

DELAY_HEADER

public const string DELAY_HEADER = "scst_delay"

Field Value

string

ROUTING_KEY_HEADER

public const string ROUTING_KEY_HEADER = "scst_routingKey"

Field Value

string

Properties

Order

Gets the order of this object

public int Order { get; }

Property Value

int

Methods

AfterReceiveCompletion(IMessage, IMessageChannel, Exception)

Invoked after the completion of a receive regardless of any exception that have been raised thus allowing for proper resource cleanup.

public void AfterReceiveCompletion(IMessage message, IMessageChannel channel, Exception exception)

Parameters

message IMessage

the message being processed

channel IMessageChannel

the channel the message is from

exception Exception

the exception that may have occured; can be null

AfterSendCompletion(IMessage, IMessageChannel, bool, Exception)

Invoked after the completion of a send regardless of any exception that have been raised thus allowing for proper resource cleanup.

public void AfterSendCompletion(IMessage message, IMessageChannel channel, bool sent, Exception exception)

Parameters

message IMessage

the message being processed

channel IMessageChannel

the channel the message for

sent bool

the return value of the send

exception Exception

the exception that may have occured; can be null

PostReceive(IMessage, IMessageChannel)

Invoked immediately after a Message has been retrieved but before it is returned to the caller.

public IMessage PostReceive(IMessage message, IMessageChannel channel)

Parameters

message IMessage

the message being processed

channel IMessageChannel

the channel the message is from

Returns

IMessage

the resulting message after post processing; can be null

PostSend(IMessage, IMessageChannel, bool)

Invoked immediately after the send invocation.

public void PostSend(IMessage message, IMessageChannel channel, bool sent)

Parameters

message IMessage

the message being processed

channel IMessageChannel

the channel the message for

sent bool

the return value of the send

PreReceive(IMessageChannel)

Invoked as soon as receive is called and before a Message is actually retrieved.

public bool PreReceive(IMessageChannel channel)

Parameters

channel IMessageChannel

the channel the message for

Returns

bool

false if no receive should be done;

PreSend(IMessage, IMessageChannel)

Invoked before the Message is actually sent to the channel. This allows for modification of the Message if necessary.

public IMessage PreSend(IMessage message, IMessageChannel channel)

Parameters

message IMessage

the message being processed

channel IMessageChannel

the channel the message for

Returns

IMessage

the resulting message to send; can be null