Interface Messenger<M>
- 
- All Known Implementing Classes:
- SingleMessenger,- TinkerMessenger
 
 public interface Messenger<M>TheMessengerserves as the routing system for messages between vertices. For distributed systems, the messenger can implement a "message passing" engine (distributed memory). For single machine systems, the messenger can implement a "state sharing" engine (shared memory). Each messenger is tied to the particular vertex distributing the message.- Author:
- Marko A. Rodriguez (http://markorodriguez.com), Matthias Broecheler (me@matthiasb.com)
 
- 
- 
Method SummaryAll Methods Instance Methods Abstract Methods Modifier and Type Method Description Iterator<M>receiveMessages()Receive all incoming messages to the currently executing vertex.voidsendMessage(MessageScope messageScope, M message)The currently executing vertex can send a message with providedMessageScope.
 
- 
- 
- 
Method Detail- 
receiveMessagesIterator<M> receiveMessages() Receive all incoming messages to the currently executing vertex.- Returns:
- the messages for the vertex
 
 - 
sendMessagevoid sendMessage(MessageScope messageScope, M message) The currently executing vertex can send a message with providedMessageScope.- Parameters:
- messageScope- the message scope of the message being sent
- message- the message to send
 
 
- 
 
-