2017-12-05 6 views
0

Ich verwende den folgenden benutzerdefinierten Prozessor zum Binden der Nachrichtenkanäle.headermode-Eigenschaften für Custom Processor, Sink und Producer

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(); 

} 

Ich versuche Header mit den folgenden Eigenschaften zu steuern, aber es ist nicht wirksam.

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

Ich habe versucht, auch in den Eigenschaften Erzeuger- und Verbraucherbindung und noch nicht wirksam.

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 

Bitte schlagen Sie für Korrekturen vor.

Antwort

1

Der Ordner weiß nichts über Ihre benutzerdefinierten Kanalnamen.

Sie müssen den korrekten Kanalnamen in der Eigenschaft verwenden, z.

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

Dies funktionierte. Danke, Gary –

Verwandte Themen