SI DSL：AMQPキューのフロー定義におけるhandle（）とchannel（）の相違

Question

私は見つけ出すことのできる文書を見直しましたが、答えは出てこなかったので、ここでいくつかの啓発を得ることを望んでいました。これらの2つの呼び出しに違いはありますか？

.handle(Amqp.outboundAdapter(amqpTemplate).routingKey("my-queue")) 
.channel(Amqp.channel(connectionFactory).queueName("my-queue")) 

Answer 1

すべてのバックReference Manualへの道のりを歩んでみましょう第一に：

より前のバージョン4.3に、AMQP担保チャンネルはSerializableをペイロードとヘッダとメッセージをサポート。メッセージ全体が変換され（シリアル化され）、RabbitMQに送信されました。これで、extract-payload属性（またはJava構成を使用するときはsetExtractPayload（））をtrueに設定できます。このフラグがtrueの場合、メッセージ・ペイロードは変換され、ヘッダーは、チャネル・アダプターを使用する場合と同様の方法でマップされます。これにより、AMQPでバックアップされたチャネルをシリアル化可能でないペイロード（おそらく、Jackson2JsonMessageConverterなどの別のメッセージコンバータ）と一緒に使用することができます。デフォルトのマップされたヘッダーについては、11.12項「AMQPメッセージヘッダー」で説明しています。 outbound-header-mapperおよびinbound-header-mapper属性を使用してカスタムマッパーを提供することによって、マッピングを変更できます。 amqp_deliveryModeヘッダーがない場合に配信モードを設定するために使用されるdefault-delivery-modeも指定できるようになりました。デフォルトでは、Spring AMQP MessagePropertiesはPERSISTENT配信モードを使用します。

したがって、通常（デフォルトで）Amqp.channel(connectionFactory)は、Message<?>全体をターゲットキューに送信します。一方Amqp.outboundAdapter(amqpTemplate)は正反対ん - bodyとヘッダに​​をマップ：

if (this.amqpTemplate instanceof RabbitTemplate) { 
     MessageConverter converter = ((RabbitTemplate) this.amqpTemplate).getMessageConverter(); 
     org.springframework.amqp.core.Message amqpMessage = MappingUtils.mapMessage(requestMessage, converter, 
       getHeaderMapper(), getDefaultDeliveryMode()); 
     addDelayProperty(requestMessage, amqpMessage); 
     ((RabbitTemplate) this.amqpTemplate).send(exchangeName, routingKey, amqpMessage, correlationData); 
} 

AMQP担保チャンネルがpersistenceを目的とされ、メッセージの内容に依存しているロジックで使用すべきではありません。