スプリングクラウドスリーとスプリングブートの統合amqp

Question

バネクラウドのスルースとスプリングブートのamqp（rabbit）パブリッシャーとサブスクライバの統合を示す例を探してください。

私は

2016年10月21日08ログに次のメッセージを参照しています：35：15.708 INFO [プロデューサー、9148f56490e5742f、943ed050691842ab、偽] 30928 --- [NIO-8080-EXEC-1] abccontrollers.MessagingController：アクティビティOrderShippedを使用して呼び出すリクエストを受け取りました 2016-10-21 08：35：15.730 INFO [プロデューサ、9148f56490e5742f、943ed050691842ab、false] 30928 --- [nio-8080-exec-1] abcservice.ProducerService ：メッセージ公開

私はQueueのメッセージを見ると、traceIdやその他の詳細がヘッダーに追加されていません。 MessagePostProcessorを使用してヘッダーに追加する必要がありますか？

また、受信サービスで何を行う必要がありますか？

Answer 1

私たちは、Spring AMQPをそのままの状態で測定しません。ただし、サポートしているSpring IntegrationまたはSpring Cloud Streamを使用することができます。何らかの理由でSpring AMQPを使用する必要がある場合は、自分でコードをインストルメントする必要があります（また、私たちにPRを送信します））。

Answer 2

Spring AMQPを使用すると、setBeforePublishPostProcessorsメソッドを使用してRabbitTemplateにMessagePostProcessorを設定できます。

私たちは、この方法をorg.springframework.amqp.core.MessagePostProcessorを実装しpostProcessMessageメソッドをオーバーライド：

@Override 
public org.springframework.amqp.core.Message postProcessMessage(org.springframework.amqp.core.Message message) 
     throws AmqpException { 
    MessagingMessageConverter converter = new MessagingMessageConverter(); 
    MessageBuilder<?> mb = MessageBuilder.fromMessage((Message<?>) converter.fromMessage(message)); 
    inject(tracer.getCurrentSpan(), mb); 
    return converter.toMessage(mb.build(), message.getMessageProperties()); 
} 

inject方法についてのメッセージに必要なすべてのヘッダーを設定することができ、それが変化してRabbitMQのに渡されます。
あなたはとても私の例は、このバージョンに基づいており、次のリリース（1.2）で、それが簡単になります私たちは、v1.1.1 of spring-cloud-sleuth-streamを使用しているorg.springframework.cloud.sleuth.instrument.messaging.MessagingSpanInjector

に、このようなinjectメソッドを実装する方法の良い例があります。