public class ReactorProcessorMessageDispatcher
extends java.lang.Object
implements org.springframework.integration.dispatcher.MessageDispatcher
| Constructor and Description |
|---|
ReactorProcessorMessageDispatcher() |
ReactorProcessorMessageDispatcher(boolean singleThreadedProducer) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
addHandler(org.springframework.integration.core.MessageHandler handler) |
boolean |
dispatch(org.springframework.integration.Message<?> message) |
boolean |
removeHandler(org.springframework.integration.core.MessageHandler handler) |
public ReactorProcessorMessageDispatcher()
public ReactorProcessorMessageDispatcher(boolean singleThreadedProducer)
public boolean addHandler(org.springframework.integration.core.MessageHandler handler)
addHandler in interface org.springframework.integration.dispatcher.MessageDispatcherpublic boolean removeHandler(org.springframework.integration.core.MessageHandler handler)
removeHandler in interface org.springframework.integration.dispatcher.MessageDispatcherpublic boolean dispatch(org.springframework.integration.Message<?> message)
dispatch in interface org.springframework.integration.dispatcher.MessageDispatcher