akka.zeromq

ZeroMQExtension

Related Docs: object ZeroMQExtension | package zeromq

class ZeroMQExtension extends Extension

The extension for the ZeroMQ module

Source
ZeroMQExtension.scala
Linear Supertypes
Type Hierarchy Learn more about scaladoc diagrams
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. ZeroMQExtension
  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
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ZeroMQExtension(system: ActorSystem)

    system

    The ActorSystem this extension belongs to.

Value Members

  1. final def !=(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Definition Classes
    AnyRef → Any
  3. def +(other: String): String

    Implicit information
    This member is added by an implicit conversion from ZeroMQExtension to any2stringadd[ZeroMQExtension] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ->[B](y: B): (ZeroMQExtension, B)

    Implicit information
    This member is added by an implicit conversion from ZeroMQExtension to ArrowAssoc[ZeroMQExtension] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  6. val DefaultPollTimeout: FiniteDuration

  7. val NewSocketTimeout: Timeout

  8. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  9. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  10. def ensuring(cond: (ZeroMQExtension) ⇒ Boolean, msg: ⇒ Any): ZeroMQExtension

    Implicit information
    This member is added by an implicit conversion from ZeroMQExtension to Ensuring[ZeroMQExtension] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  11. def ensuring(cond: (ZeroMQExtension) ⇒ Boolean): ZeroMQExtension

    Implicit information
    This member is added by an implicit conversion from ZeroMQExtension to Ensuring[ZeroMQExtension] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  12. def ensuring(cond: Boolean, msg: ⇒ Any): ZeroMQExtension

    Implicit information
    This member is added by an implicit conversion from ZeroMQExtension to Ensuring[ZeroMQExtension] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  13. def ensuring(cond: Boolean): ZeroMQExtension

    Implicit information
    This member is added by an implicit conversion from ZeroMQExtension to Ensuring[ZeroMQExtension] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  14. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  15. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  16. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  17. def formatted(fmtstr: String): String

    Implicit information
    This member is added by an implicit conversion from ZeroMQExtension to StringFormat[ZeroMQExtension] performed by method StringFormat in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()
  18. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  19. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  20. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  21. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  22. def newDealerSocket(socketParameters: Array[SocketOption]): ActorRef

    Java API factory method to create the actor representing the ZeroMQ Dealer socket.

    Java API factory method to create the actor representing the ZeroMQ Dealer socket. You can pass in as many configuration options as you want and the order of the configuration options doesn't matter They are matched on type and the first one found wins.

    socketParameters

    array of akka.zeromq.SocketOption to configure the socket

    returns

    the akka.actor.ActorRef

  23. def newDealerSocketProps(socketParameters: SocketOption*): Props

    Java API: Factory method to create the akka.actor.Props to build a ZeroMQ Dealer socket actor.

    Java API: Factory method to create the akka.actor.Props to build a ZeroMQ Dealer socket actor.

    socketParameters

    a varargs list of akka.zeromq.SocketOption to configure the socket

    returns

    the akka.actor.Props

  24. def newPubSocket(bind: Bind): ActorRef

    Convenience for creating a publisher socket.

  25. def newPubSocket(socketParameters: Array[SocketOption]): ActorRef

    Java API factory method to create the actor representing the ZeroMQ Publisher socket.

    Java API factory method to create the actor representing the ZeroMQ Publisher socket. You can pass in as many configuration options as you want and the order of the configuration options doesn't matter They are matched on type and the first one found wins.

    socketParameters

    array of akka.zeromq.SocketOption to configure the socket

    returns

    the akka.actor.ActorRef

  26. def newPubSocketProps(socketParameters: SocketOption*): Props

    Java API: Factory method to create the akka.actor.Props to build a ZeroMQ Publisher socket actor.

    Java API: Factory method to create the akka.actor.Props to build a ZeroMQ Publisher socket actor.

    socketParameters

    a varargs list of akka.zeromq.SocketOption to configure the socket

    returns

    the akka.actor.Props

  27. def newPullSocket(socketParameters: Array[SocketOption]): ActorRef

    Java API factory method to create the actor representing the ZeroMQ Pull socket.

    Java API factory method to create the actor representing the ZeroMQ Pull socket. You can pass in as many configuration options as you want and the order of the configuration options doesn't matter They are matched on type and the first one found wins.

    socketParameters

    array of akka.zeromq.SocketOption to configure the socket

    returns

    the akka.actor.ActorRef

  28. def newPullSocketProps(socketParameters: SocketOption*): Props

    Java API: Factory method to create the akka.actor.Props to build a ZeroMQ Pull socket actor.

    Java API: Factory method to create the akka.actor.Props to build a ZeroMQ Pull socket actor.

    socketParameters

    a varargs list of akka.zeromq.SocketOption to configure the socket

    returns

    the akka.actor.Props

  29. def newPushSocket(socketParameters: Array[SocketOption]): ActorRef

    Java API factory method to create the actor representing the ZeroMQ Push socket.

    Java API factory method to create the actor representing the ZeroMQ Push socket. You can pass in as many configuration options as you want and the order of the configuration options doesn't matter They are matched on type and the first one found wins.

    socketParameters

    array of akka.zeromq.SocketOption to configure the socket

    returns

    the akka.actor.ActorRef

  30. def newPushSocketProps(socketParameters: SocketOption*): Props

    Java API: Factory method to create the akka.actor.Props to build a ZeroMQ Push socket actor.

    Java API: Factory method to create the akka.actor.Props to build a ZeroMQ Push socket actor.

    socketParameters

    a varargs list of akka.zeromq.SocketOption to configure the socket

    returns

    the akka.actor.Props

  31. def newRepSocket(socketParameters: Array[SocketOption]): ActorRef

    Java API factory method to create the actor representing the ZeroMQ Rep socket.

    Java API factory method to create the actor representing the ZeroMQ Rep socket. You can pass in as many configuration options as you want and the order of the configuration options doesn't matter They are matched on type and the first one found wins.

    socketParameters

    array of akka.zeromq.SocketOption to configure the socke

    returns

    the akka.actor.ActorRef

  32. def newRepSocketProps(socketParameters: SocketOption*): Props

    Java API: Factory method to create the akka.actor.Props to build a ZeroMQ Rep socket actor.

    Java API: Factory method to create the akka.actor.Props to build a ZeroMQ Rep socket actor.

    socketParameters

    a varargs list of akka.zeromq.SocketOption to configure the socket

    returns

    the akka.actor.Props

  33. def newReqSocket(socketParameters: Array[SocketOption]): ActorRef

    Java API factory method to create the actor representing the ZeroMQ Req socket.

    Java API factory method to create the actor representing the ZeroMQ Req socket. You can pass in as many configuration options as you want and the order of the configuration options doesn't matter They are matched on type and the first one found wins.

    socketParameters

    array of akka.zeromq.SocketOption to configure the socket

    returns

    the akka.actor.ActorRef

  34. def newReqSocketProps(socketParameters: SocketOption*): Props

    Java API: Factory method to create the akka.actor.Props to build a ZeroMQ Req socket actor.

    Java API: Factory method to create the akka.actor.Props to build a ZeroMQ Req socket actor.

    socketParameters

    a varargs list of akka.zeromq.SocketOption to configure the socket

    returns

    the akka.actor.Props

  35. def newRouterSocket(socketParameters: Array[SocketOption]): ActorRef

    Java API factory method to create the actor representing the ZeroMQ Router socket.

    Java API factory method to create the actor representing the ZeroMQ Router socket. You can pass in as many configuration options as you want and the order of the configuration options doesn't matter They are matched on type and the first one found wins.

    socketParameters

    array of akka.zeromq.SocketOption to configure the socket

    returns

    the akka.actor.ActorRef

  36. def newRouterSocketProps(socketParameters: SocketOption*): Props

    Java API: Factory method to create the akka.actor.Props to build a ZeroMQ Router socket actor.

    Java API: Factory method to create the akka.actor.Props to build a ZeroMQ Router socket actor.

    socketParameters

    a varargs list of akka.zeromq.SocketOption to configure the socket

    returns

    the akka.actor.Props

  37. def newSocket(socketParameters: SocketOption*): ActorRef

    Factory method to create the actor representing the ZeroMQ socket.

    Factory method to create the actor representing the ZeroMQ socket. You can pass in as many configuration options as you want and the order of the configuration options doesn't matter They are matched on type and the first one found wins.

    socketParameters

    a varargs list of akka.zeromq.SocketOption to configure the socke

    returns

    the akka.actor.ActorRef

  38. def newSocketProps(socketParameters: SocketOption*): Props

    Factory method to create the akka.actor.Props to build the ZeroMQ socket actor.

    Factory method to create the akka.actor.Props to build the ZeroMQ socket actor.

    socketParameters

    a varargs list of akka.zeromq.SocketOption to configure the socket

    returns

    the akka.actor.Props

  39. def newSubSocket(connect: Connect, listener: Listener, subscribe: Subscribe): ActorRef

    Convenience for creating a subscriber socket.

  40. def newSubSocket(socketParameters: Array[SocketOption]): ActorRef

    Java API factory method to create the actor representing the ZeroMQ Subscriber socket.

    Java API factory method to create the actor representing the ZeroMQ Subscriber socket. You can pass in as many configuration options as you want and the order of the configuration options doesn't matter They are matched on type and the first one found wins.

    socketParameters

    array of akka.zeromq.SocketOption to configure the socket

    returns

    the akka.actor.ActorRef

  41. def newSubSocketProps(socketParameters: SocketOption*): Props

    Java API: Factory method to create the akka.actor.Props to build a ZeroMQ Subscriber socket actor.

    Java API: Factory method to create the akka.actor.Props to build a ZeroMQ Subscriber socket actor.

    socketParameters

    a varargs list of akka.zeromq.SocketOption to configure the socket

    returns

    the akka.actor.Props

  42. final def notify(): Unit

    Definition Classes
    AnyRef
  43. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  44. val pollTimeUnit: TimeUnit

  45. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  46. def toString(): String

    Definition Classes
    AnyRef → Any
  47. def version: ZeroMQVersion

    The version of the ZeroMQ library

    The version of the ZeroMQ library

    returns

    a akka.zeromq.ZeroMQVersion

  48. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  49. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  50. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  51. def [B](y: B): (ZeroMQExtension, B)

    Implicit information
    This member is added by an implicit conversion from ZeroMQExtension to ArrowAssoc[ZeroMQExtension] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Inherited from Extension

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from ZeroMQExtension to any2stringadd[ZeroMQExtension]

Inherited by implicit conversion StringFormat from ZeroMQExtension to StringFormat[ZeroMQExtension]

Inherited by implicit conversion Ensuring from ZeroMQExtension to Ensuring[ZeroMQExtension]

Inherited by implicit conversion ArrowAssoc from ZeroMQExtension to ArrowAssoc[ZeroMQExtension]

Ungrouped