public class DefaultMessageRouter extends Object implements MessageRouter
Constructor and Description |
---|
DefaultMessageRouter() |
DefaultMessageRouter(Collection<Object> messagingAgents) |
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.
|
public DefaultMessageRouter()
public DefaultMessageRouter(Collection<Object> messagingAgents)
public final void registerMessagingAgent(Object agent)
MessageRouter
registerMessagingAgent
in interface MessageRouter
Consumes
,
Produces
public void unregisterMessagingAgent(Object agent)
MessageRouter
unregisterMessagingAgent
in interface MessageRouter
public void consume(Message message, MessageContext context)
MessageRouter
consume
in interface MessageRouter
public void produce(Consumer<Message> messageConsumer, MessageContext context)
MessageRouter
produce
in interface MessageRouter
Copyright © 2016–2021. All rights reserved.