Fix Checkstyle violations
* Fix new Sonar smells
This commit is contained in:
@@ -117,7 +117,7 @@ public class FluxMessageChannel extends AbstractMessageChannel
|
||||
.publishOn(this.scheduler)
|
||||
.flatMap((message) ->
|
||||
Mono.just(message)
|
||||
.handle((messageToHandle, sink) -> sendReactiveMessage(messageToHandle))
|
||||
.handle((messageToHandle, syncSink) -> sendReactiveMessage(messageToHandle))
|
||||
.contextWrite(StaticMessageHeaderAccessor.getReactorContext(message)))
|
||||
.contextCapture()
|
||||
.subscribe());
|
||||
|
||||
@@ -40,8 +40,6 @@ public class ContextHolderRequestHandlerAdvice extends AbstractRequestHandlerAdv
|
||||
|
||||
public final Runnable contextClearHook;
|
||||
|
||||
private boolean enableContextPropagation;
|
||||
|
||||
/**
|
||||
* Construct an instance based on the provided hooks.
|
||||
* @param valueProvider The key provider function.
|
||||
|
||||
Reference in New Issue
Block a user