Class NcsMessageEnvironment

    • Method Detail

      • setupListener

        public <T> void setupListener​(java.lang.String listenerId,
                                      MessageListener<T> listener)
        Description copied from interface: MessageEnvironment
        Set up a MessageListener with a listener id.
        Specified by:
        setupListener in interface MessageEnvironment
        Type Parameters:
        T - The type of the message to be sent in the environment
        Parameters:
        listenerId - an identifier of the message listener
        listener - a message listener
      • asyncConnect

        public <T> java.util.concurrent.Future<MessageSender<T>> asyncConnect​(java.lang.String receiverId,
                                                                              java.lang.String listenerId)
        Description copied from interface: MessageEnvironment
        Asynchronously connect to the node called receiverId and return a future of MessageSender that sends messages to the listener with listenerId.
        Specified by:
        asyncConnect in interface MessageEnvironment
        Type Parameters:
        T - The type of the message to be sent in the environment
        Parameters:
        receiverId - a receiver id
        listenerId - an identifier of the message listener
        Returns:
        a message sender
      • getId

        public java.lang.String getId()
        Specified by:
        getId in interface MessageEnvironment
        Returns:
        identifier for this node
      • close

        public void close()
                   throws java.lang.Exception
        Description copied from interface: MessageEnvironment
        Close this message environment.
        Specified by:
        close in interface MessageEnvironment
        Throws:
        java.lang.Exception - while closing