Class SingleMessenger<M>

  • All Implemented Interfaces:
    Messenger<M>

    public final class SingleMessenger<M>
    extends Object
    implements Messenger<M>
    Author:
    Marko A. Rodriguez (http://markorodriguez.com)
    • Constructor Detail

      • SingleMessenger

        public SingleMessenger​(Messenger<M> baseMessenger,
                               M message)
    • Method Detail

      • receiveMessages

        public Iterator<M> receiveMessages()
        Description copied from interface: Messenger
        Receive all incoming messages to the currently executing vertex.
        Specified by:
        receiveMessages in interface Messenger<M>
        Returns:
        the messages for the vertex
      • sendMessage

        public void sendMessage​(MessageScope messageScope,
                                M message)
        Description copied from interface: Messenger
        The currently executing vertex can send a message with provided MessageScope.
        Specified by:
        sendMessage in interface Messenger<M>
        Parameters:
        messageScope - the message scope of the message being sent
        message - the message to send