Constructor and Description |
---|
SingleMessenger(Messenger<M> baseMessenger,
M message) |
Modifier and Type | Method and Description |
---|---|
Iterator<M> |
receiveMessages()
Receive all incoming messages to the currently executing vertex.
|
void |
sendMessage(MessageScope messageScope,
M message)
The currently executing vertex can send a message with provided
MessageScope . |
public Iterator<M> receiveMessages()
Messenger
receiveMessages
in interface Messenger<M>
public void sendMessage(MessageScope messageScope, M message)
Messenger
MessageScope
.sendMessage
in interface Messenger<M>
messageScope
- the message scope of the message being sentmessage
- the message to sendCopyright © 2013–2018 Apache Software Foundation. All rights reserved.