0

Spring AMQP を使用して RabbitMQ で非同期呼び出しを実行しようとしています。Spring amqp を使用して、replyqueue、correlationId、(プロパティ) を構成する方法を教えてください。

    String corrId = java.util.UUID.randomUUID().toString();

 BasicProperties props = new BasicProperties
                                .Builder()
                                .correlationId(corrId)
                                .replyTo(replyQueueName)
                                .build();

 channel.basicPublish("", requestQueueName, props, message.getBytes());
4

1 に答える 1

1

私はあなたが使用する必要があると仮定しますRabbitTemplate:

rabbitTemplate.convertAndSend(requestQueueName, myObj, new MessagePostProcessor() {
   Message postProcessMessage(Message message) throws AmqpException {
      message.getMessageProperties().setReplyTo(replyQueueName);
      return message;  
   }
}, new CorrelationData(corrId));

HTH

于 2013-11-08T10:04:52.937 に答える