Package akka.cluster.ddata.typed.javadsl
Class Replicator.Subscribe<A extends ReplicatedData>
- java.lang.Object
-
- akka.cluster.ddata.typed.javadsl.Replicator.Subscribe<A>
-
- All Implemented Interfaces:
Replicator.Command
,Replicator.Command
,java.io.Serializable
,scala.Equals
,scala.Product
- Enclosing class:
- Replicator
public static final class Replicator.Subscribe<A extends ReplicatedData> extends java.lang.Object implements Replicator.Command, scala.Product, java.io.Serializable
Register a subscriber that will be notified with aReplicator.Changed
message when the value of the givenkey
is changed. Current value is also sent as aReplicator.Changed
message to a new subscriber.Subscribers will be notified periodically with the configured
notify-subscribers-interval
, and it is also possible to send an explicitFlushChanges
message to theReplicator
to notify the subscribers immediately.The subscriber will automatically be unregistered if it is terminated.
If the key is deleted the subscriber is notified with a
Replicator.Deleted
message.If the key is expired the subscriber is notified with a
Replicator.Expired
message.- See Also:
- Serialized Form
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
canEqual(java.lang.Object x$1)
<A extends ReplicatedData>
Replicator.Subscribe<A>copy(Key<A> key, ActorRef<Replicator.SubscribeResponse<A>> subscriber)
<A extends ReplicatedData>
Key<A>copy$default$1()
<A extends ReplicatedData>
ActorRef<Replicator.SubscribeResponse<A>>copy$default$2()
boolean
equals(java.lang.Object x$1)
int
hashCode()
Key<A>
key()
int
productArity()
java.lang.Object
productElement(int x$1)
java.lang.String
productElementName(int x$1)
scala.collection.Iterator<java.lang.Object>
productIterator()
java.lang.String
productPrefix()
ActorRef<Replicator.SubscribeResponse<A>>
subscriber()
java.lang.String
toString()
-
-
-
Constructor Detail
-
Subscribe
public Subscribe(Key<A> key, ActorRef<Replicator.SubscribeResponse<A>> subscriber)
-
-
Method Detail
-
subscriber
public ActorRef<Replicator.SubscribeResponse<A>> subscriber()
-
copy
public <A extends ReplicatedData> Replicator.Subscribe<A> copy(Key<A> key, ActorRef<Replicator.SubscribeResponse<A>> subscriber)
-
copy$default$1
public <A extends ReplicatedData> Key<A> copy$default$1()
-
copy$default$2
public <A extends ReplicatedData> ActorRef<Replicator.SubscribeResponse<A>> copy$default$2()
-
productPrefix
public java.lang.String productPrefix()
- Specified by:
productPrefix
in interfacescala.Product
-
productArity
public int productArity()
- Specified by:
productArity
in interfacescala.Product
-
productElement
public java.lang.Object productElement(int x$1)
- Specified by:
productElement
in interfacescala.Product
-
productIterator
public scala.collection.Iterator<java.lang.Object> productIterator()
- Specified by:
productIterator
in interfacescala.Product
-
canEqual
public boolean canEqual(java.lang.Object x$1)
- Specified by:
canEqual
in interfacescala.Equals
-
productElementName
public java.lang.String productElementName(int x$1)
- Specified by:
productElementName
in interfacescala.Product
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object x$1)
- Specified by:
equals
in interfacescala.Equals
- Overrides:
equals
in classjava.lang.Object
-
-