t

scredis.commands

PubSubCommands

trait PubSubCommands extends AnyRef

This trait implements pub/sub commands.

Self Type
PubSubCommands with NonBlockingConnection
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PubSubCommands
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  14. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  15. def pubSubChannels(patternOpt: Option[String] = None): Future[List[String]]

    Lists the currently active channels.

    Lists the currently active channels. An active channel is a Pub/Sub channel with one or more subscribers (not including clients subscribed to patterns).

    patternOpt

    optional pattern to filter returned channels

    returns

    the currently active channels, optionally matching the specified pattern

    Since

    2.8.0

    Note

    If no pattern is specified, all the channels are listed, otherwise if pattern is specified only channels matching the specified glob-style pattern are listed.

  16. def pubSubNumPat(): Future[Long]

    Returns the number of subscriptions to patterns (that are performed using the PSUBSCRIBE command).

    Returns the number of subscriptions to patterns (that are performed using the PSUBSCRIBE command).

    returns

    the number of subscriptions to patterns

    Since

    2.8.0

    Note

    Note that this is not just the count of clients subscribed to patterns but the total number of patterns all the clients are subscribed to.

  17. def pubSubNumSub(channels: String*): Future[Map[String, Long]]

    Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels.

    Returns the number of subscribers (not counting clients subscribed to patterns) for the specified channels.

    channels

    channel name(s)

    returns

    a map of channels to number of subscribers for every provided channel

    Since

    2.8.0

  18. def publish[W](channel: String, message: W)(implicit arg0: Writer[W]): Future[Long]

    Publishes a message to a channel.

    Publishes a message to a channel.

    channel

    the name of the channel

    message

    the message payload

    returns

    the number of clients that received the message

    Since

    2.0.0

  19. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  20. def toString(): String
    Definition Classes
    AnyRef → Any
  21. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  22. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  23. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped