Class Subscribe<A extends ClusterEvent.ClusterDomainEvent>

  • All Implemented Interfaces:
    ClusterStateSubscription, java.io.Serializable, scala.Equals, scala.Product

    public final class Subscribe<A extends ClusterEvent.ClusterDomainEvent>
    extends java.lang.Object
    implements ClusterStateSubscription, scala.Product, java.io.Serializable
    Subscribe to cluster state changes. The initial state of the cluster will be sent as a "replay" of the subscribed events.

    param: subscriber A subscriber that will receive events until it is unsubscribed or stops param: eventClass The type of events to subscribe to, can be individual event types such as ReachabilityEvent or one of the common supertypes, such as MemberEvent to get all the subtypes of events.

    See Also:
    Serialized Form
    • Constructor Detail

      • Subscribe

        public Subscribe​(ActorRef<A> subscriber,
                         java.lang.Class<A> eventClass)
    • Method Detail

      • subscriber

        public ActorRef<A> subscriber()
      • eventClass

        public java.lang.Class<A> eventClass()
      • productPrefix

        public java.lang.String productPrefix()
        Specified by:
        productPrefix in interface scala.Product
      • productArity

        public int productArity()
        Specified by:
        productArity in interface scala.Product
      • productElement

        public java.lang.Object productElement​(int x$1)
        Specified by:
        productElement in interface scala.Product
      • productIterator

        public scala.collection.Iterator<java.lang.Object> productIterator()
        Specified by:
        productIterator in interface scala.Product
      • canEqual

        public boolean canEqual​(java.lang.Object x$1)
        Specified by:
        canEqual in interface scala.Equals
      • productElementName

        public java.lang.String productElementName​(int x$1)
        Specified by:
        productElementName in interface scala.Product
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • equals

        public boolean equals​(java.lang.Object x$1)
        Specified by:
        equals in interface scala.Equals
        Overrides:
        equals in class java.lang.Object