2017-12-05 8 views
0

メッセージチャネルをバインドするために、次のカスタムプロセッサを使用しています。カスタムプロセッサ、シンクおよびプロデューサのヘッドモードプロパティ

package test; 

import org.springframework.cloud.stream.annotation.Input; 
import org.springframework.cloud.stream.annotation.Output; 
import org.springframework.messaging.MessageChannel; 
import org.springframework.messaging.SubscribableChannel; 

public interface ProcessorInput { 

    String INPUT_CHANNEL = "test1"; 
    String OUTPUT_CHANNEL = "test2"; 

    @Input(INPUT_CHANNEL) 
    MessageChannel inputchannel(); 

    @Output(OUTPUT_CHANNEL) 
    SubscribableChannel outputchannel(); 

} 

以下のプロパティでヘッダーを制御しようとしていますが、効果がありません。

spring.cloud.stream.bindings.output.producer.headerMode=raw 
spring.cloud.stream.bindings.input.consumer.headerMode=raw 

また、プロパティでプロデューサとコンシューマをバインドしても効果はありません。

spring.cloud.stream.bindings.output.consumer=test1 
spring.cloud.stream.bindings.input.producer=test2 
spring.cloud.stream.bindings.output.producer.headerMode=raw 
spring.cloud.stream.bindings.input.consumer.headerMode=raw 

訂正してください。

答えて

1

バインダーにはカスタムチャンネル名は何も分かりません。

プロパティで正しいチャンネル名を使用する必要があります(例:

spring.cloud.stream.bindings.test2.producer.headerMode=raw 
+0

これは機能しました。ありがとう、ゲイリー –

関連する問題