反応的な@StreamListener

Question

ちょっと速い。

反応する@StreamListener入力をSpring Cloud Streamで使用することは可能ですか？私はそれによって意味することは、このようなものである。このような

@StreamListener(Sink.INPUT) 
public void log(String message) 
{ 
    log.info(message); 
} 

またはプロセッサの：ドキュメントで

@StreamListener 
public void log(@Input(Sink.INPUT) Flux<String> strings) 
{ 
    strings.log(); 
} 

私はこのような例を見て

@StreamListener 
@Output(Source.OUTPUT) 
public Flux<String> log(@Input(Sink.INPUT) Flux<String> strings) 
{ 
    return strings.map(String::toUpperCase); 
} 

私は実行最初のスニペットのコードはDispatcher has no subscribers例外です。

Answer 1

最初の2つは同等です。エラーが発生した場合は、GitHubの問題を開いてください。

EDIT：

2つの注釈は同等ですが、入力されたフラックスのサブスクリプションがある場合、リスナーは入力のみに加入します。完全に同等であるためには、反応1は次のようになります。単純に、フラックスにlog()を呼び出す

@StreamListener 
public void log(@Input(Sink.INPUT) Flux<String> strings) 
{ 
    strings.log().subscribe(); 
} 

または

@StreamListener 
public void log(@Input(Sink.INPUT) Flux<String> strings) 
{ 
    strings.subscribe(log::info); 
} 

は、独自のサブスクリプションなしで別のFluxを作成します。