org.springframework.cloud.stream.binder.rabbit

Class RabbitExpressionEvaluatingInterceptor

java.lang.Object

org.springframework.messaging.support.ChannelInterceptorAdapter

org.springframework.cloud.stream.binder.rabbit.RabbitExpressionEvaluatingInterceptor

All Implemented Interfaces:

org.springframework.messaging.support.ChannelInterceptor

public class RabbitExpressionEvaluatingInterceptor
extends org.springframework.messaging.support.ChannelInterceptorAdapter

Interceptor to evaluate expressions for outbound messages before serialization.

Since:

2.0

Author:

Gary Russell

Field Summary

Fields

Modifier and Type	Field and Description
static String	DELAY_HEADER
static org.springframework.expression.ExpressionParser	PARSER
static String	ROUTING_KEY_HEADER

Constructor Summary

Constructors

Constructor and Description
RabbitExpressionEvaluatingInterceptor(String routingKeyExpression, String delayExpression, org.springframework.expression.EvaluationContext evaluationContext) Construct an instance with the provided expressions and evaluation context.

Method Summary

Modifier and Type	Method and Description
org.springframework.messaging.Message<?>	preSend(org.springframework.messaging.Message<?> message, org.springframework.messaging.MessageChannel channel)

Methods inherited from class org.springframework.messaging.support.ChannelInterceptorAdapter

afterReceiveCompletion, afterSendCompletion, postReceive, postSend, preReceive

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

PARSER

public static final org.springframework.expression.ExpressionParser PARSER

ROUTING_KEY_HEADER

public static final String ROUTING_KEY_HEADER

See Also:

Constant Field Values

DELAY_HEADER

public static final String DELAY_HEADER

See Also:

Constant Field Values

Constructor Detail

RabbitExpressionEvaluatingInterceptor

public RabbitExpressionEvaluatingInterceptor(String routingKeyExpression,
                                             String delayExpression,
                                             org.springframework.expression.EvaluationContext evaluationContext)

Construct an instance with the provided expressions and evaluation context. At least one expression muse be non-null.

Parameters:

routingKeyExpression - the routing key expresssion.

delayExpression - the delay expression.

evaluationContext - the evaluation context.

Method Detail

preSend

public org.springframework.messaging.Message<?> preSend(org.springframework.messaging.Message<?> message,
                                                        org.springframework.messaging.MessageChannel channel)

Specified by:

preSend in interface org.springframework.messaging.support.ChannelInterceptor

Overrides:

preSend in class org.springframework.messaging.support.ChannelInterceptorAdapter