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
訂正してください。
これは機能しました。ありがとう、ゲイリー –