Packages

package consumer

Type Members

  1. class ClusterPeerListProvider extends () ⇒ Set[NetworkPeer]

    It provides current list of active peers in the cluster.

  2. class ClusteredNetworkMessageConsumer extends StandardNetworkMessageConsumer

    This network message consumer composes inherited NetworkTalker to allow communication in both directions.

    This network message consumer composes inherited NetworkTalker to allow communication in both directions. Message handler is provided with incoming NetworkMessage, instance of Talker that can be used to send a response and ClusterPeerListProvider which provides list of currently active peers.

Ungrouped