代码之家 › 专栏 › 技术社区 › nemo

使用Spring AMQP注释驱动的回复(@sentto)发布进程消息

spring-amqp

nemo · 技术社区 · 6 年前

我正在尝试使用 @SentTo 根据此处的文档,将返回值发送到rabbitmq exchange的注释: https://docs.spring.io/spring-amqp/reference/htmlsingle/#async-annotation-driven-reply

如果我需要设置Heraders,文件上说要返回 Message<OrderStatus> 并使用 MessageBuilder .

但是,我需要设置 correlationId 消息属性和 消息生成器 我没有办法设置属性,只有标题。

如何使用 @ SentTo 注释?

amqpTemplate.convertAndSend(
  amqpRoutingKey,
  orderStatus,
  message -> {
    message.getMessageProperties().setCorrelationId(orderStatus.getCorrelationId().toString());
    return message;
  }
);

谢谢!

1 回复 | 直到 6 年前

Artem Bilan 6 年前

/**
 * Makes this builder's properties builder use a reference to properties.
 * @param properties The properties.
 * @return this.
 */
public MessageBuilder andProperties(MessageProperties properties) {

MessageBuilder message.getMessageProperties().setCorrelationId()

AbstractRabbitListenerContainerFactory

/**
 * Set post processors that will be applied before sending replies.
 * @param beforeSendReplyPostProcessors the post processors.
 * @since 2.0.3
 */
public void setBeforeSendReplyPostProcessors(MessagePostProcessor... beforeSendReplyPostProcessors) {

org.springframework.messaging.support.MessageBuilder AmqpHeaders.CORRELATION_ID CorrelationId

/**
 * Post-process the given response message before it will be sent.
 * <p>
 * The default implementation sets the response's correlation id to the request message's correlation id, if any;
 * otherwise to the request message id.
 * @param request the original incoming Rabbit message
 * @param response the outgoing Rabbit message about to be sent
 */
protected void postProcessResponse(Message request, Message response) {
    String correlation = request.getMessageProperties().getCorrelationId();

    if (correlation == null) {
        String messageId = request.getMessageProperties().getMessageId();
        if (messageId != null) {
            correlation = messageId;
        }
    }
    response.getMessageProperties().setCorrelationId(correlation);
}

推荐文章

megna · convertAndSend方法的正确用法是什么?

6 年前

Johan · 在SimpleRabbitListenerContainerFactory中使用RetryInterceptorBuilder重试时,如何启用异常日志记录?

6 年前

megna · 弹簧兔AMQP

6 年前

kinbiko · 在春季amqp中,阅读兔子信息的最早切入点是什么?

7 年前

JvmSd121 · 默认为content\u类型的应用程序/json,覆盖了DefaultExceptionStrategy中的isFatal

7 年前

SanketKD · 为什么Spring引导应用程序记录在添加Spring云总线依赖项后启动了两次

7 年前

Alex · RabbitMQ按类型分离侦听器

7 年前

Josh Chappelle · Spring Amqp Hibernate vs Rabbit事务管理器

7 年前

jandres · Spring AMQP和CachingConnectionFactory

7 年前

bluemind · 为什么带有Jackson2JsonMessageConverter的AmqpChannelFactoryBean不存储类型?

7 年前