| Constructor and Description |
|---|
TinkerMessenger(Vertex vertex,
org.apache.tinkerpop.gremlin.tinkergraph.process.computer.TinkerMessageBoard<M> messageBoard,
Optional<MessageCombiner<M>> combiner) |
| 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 TinkerMessenger(Vertex vertex, org.apache.tinkerpop.gremlin.tinkergraph.process.computer.TinkerMessageBoard<M> messageBoard, Optional<MessageCombiner<M>> combiner)
public Iterator<M> receiveMessages()
MessengerreceiveMessages in interface Messenger<M>public void sendMessage(MessageScope messageScope, M message)
MessengerMessageScope.sendMessage in interface Messenger<M>messageScope - the message scope of the message being sentmessage - the message to sendCopyright © 2013–2015 Apache Software Foundation. All rights reserved.