Type Members

1.  final case class CountSubscribers(topic: String) extends Product with Serializable
2.  final case class CurrentTopics(topics: Set[String]) extends Product with Serializable

   Reply to GetTopics.

   Reply to GetTopics.

   Annotations

   @SerialVersionUID()

3.  sealed abstract class GetTopics extends AnyRef
4.  final case class Publish(topic: String, msg: Any, sendOneMessageToEachGroup: Boolean) extends DistributedPubSubMessage with Product with Serializable

   Annotations

   @SerialVersionUID()

5.  final case class Put(ref: ActorRef) extends Product with Serializable

   Annotations

   @SerialVersionUID()

6.  final case class Remove(path: String) extends Product with Serializable

   Annotations

   @SerialVersionUID()

7.  final case class Send(path: String, msg: Any, localAffinity: Boolean) extends DistributedPubSubMessage with Product with Serializable

   Annotations

   @SerialVersionUID()

8.  final case class SendToAll(path: String, msg: Any, allButSelf: Boolean = false) extends DistributedPubSubMessage with Product with Serializable

   Annotations

   @SerialVersionUID()

9.  final case class Subscribe(topic: String, group: Option[String], ref: ActorRef) extends Product with Serializable

   Annotations

   @SerialVersionUID()

10.  final case class SubscribeAck(subscribe: Subscribe) extends DeadLetterSuppression with Product with Serializable

    Annotations

    @SerialVersionUID()

11.  final case class Unsubscribe(topic: String, group: Option[String], ref: ActorRef) extends Product with Serializable

    Annotations

    @SerialVersionUID()

12.  final case class UnsubscribeAck(unsubscribe: Unsubscribe) extends Product with Serializable

    Annotations

    @SerialVersionUID()