Interface Messenger<M>

  • public interface Messenger<M>
    The Messenger 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.
    Marko A. Rodriguez (, Matthias Broecheler (
    • Method Detail

      • receiveMessages

        Iterator<M> receiveMessages()
        Receive all incoming messages to the currently executing vertex.
        the messages for the vertex
      • sendMessage

        void sendMessage​(MessageScope messageScope,
                         M message)
        The currently executing vertex can send a message with provided MessageScope.
        messageScope - the message scope of the message being sent
        message - the message to send