public interface MessageRouter
Modifier and Type | Method and Description |
---|---|
void |
consume(Message message,
MessageContext context)
Route a message to consumers.
|
void |
produce(Consumer<Message> messageConsumer,
MessageContext context)
Request a message from producers.
|
void |
registerMessagingAgent(Object agent)
Add a messaging agent, that can act as a message consumer and/or producer.
|
void |
unregisterMessagingAgent(Object agent)
Remove a messaging agent, if it's registered in this message router.
|
void consume(Message message, MessageContext context)
void produce(Consumer<Message> messageConsumer, MessageContext context)
void registerMessagingAgent(Object agent)
void unregisterMessagingAgent(Object agent)
Copyright © 2016–2021. All rights reserved.