final class PubSub extends Extension

Source
PubSub.scala
Linear Supertypes
Extension, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PubSub
  2. Extension
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new PubSub(system: ActorSystem[_])

Value Members

  1. def currentTopics: Set[String]

    Scala API: return the current set of running topics

  2. def getCurrentTopics(): Set[String]

    Java API: return the current set of running topics

  3. def topic[T](messageClass: Class[T], name: String, ttl: Duration): [Command[T]]

    Scala API: Spawn an actor with the given topic name or share an existing one if it is already running.

    Scala API: Spawn an actor with the given topic name or share an existing one if it is already running.

    Note that Topic actors manually started will not be part of this registry.

    T

    the type of messages the topic accepts for publishing and subscribing

    ttl

    If the topic is idle this long, shut the actor down. All calls to topic for the same topic name should use the same ttl.

  4. def topic[T](messageClass: Class[T], name: String): [Command[T]]

    Java API: Spawn an actor with the given topic name or share an existing one if it is already running.

    Java API: Spawn an actor with the given topic name or share an existing one if it is already running.

    Note that Topic actors manually started will not be part of this registry.

    messageClass

    the type of messages the topic accepts for publishing and subscribing

  5. def topic[T](name: String, ttl: FiniteDuration)(implicit classTag: ClassTag[T]): [Command[T]]

    Scala API: Spawn an actor with the given topic name or share an existing one if it is already running.

    Scala API: Spawn an actor with the given topic name or share an existing one if it is already running.

    Note that Topic actors manually started will not be part of this registry.

    T

    the type of messages the topic accepts for publishing and subscribing

    ttl

    If the topic is idle this long, shut the actor down. All calls to topic for the same topic name should use the same ttl.

  6. def topic[T](name: String)(implicit classTag: ClassTag[T]): [Command[T]]

    Scala API: Spawn an actor with the given topic name or share an existing one if it is already running.

    Scala API: Spawn an actor with the given topic name or share an existing one if it is already running.

    Note that Topic actors manually started will not be part of this registry.

    T

    the type of messages the topic accepts for publishing and subscribing