Interface Messenger<M>
-
public interface Messenger<M>
TheMessenger
serves 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 Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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 providedMessageScope
.
-
-
-
Method Detail
-
receiveMessages
Iterator<M> receiveMessages()
Receive all incoming messages to the currently executing vertex.- Returns:
- the messages for the vertex
-
sendMessage
void sendMessage(MessageScope messageScope, M message)
The currently executing vertex can send a message with providedMessageScope
.- Parameters:
messageScope
- the message scope of the message being sentmessage
- the message to send
-
-