|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.zeromq.ZeroMQExtension
public class ZeroMQExtension
The extension for the ZeroMQ module
param: system The ActorSystem this extension belongs to.
Constructor Summary | |
---|---|
ZeroMQExtension(ActorSystem system)
|
Method Summary | |
---|---|
static ZeroMQExtension |
createExtension(ExtendedActorSystem system)
|
scala.concurrent.duration.FiniteDuration |
DefaultPollTimeout()
|
static ZeroMQExtension |
get(ActorSystem system)
|
static ZeroMQExtension$ |
lookup()
|
ActorRef |
newDealerSocket(SocketOption[] socketParameters)
Java API factory method to create the actor representing the ZeroMQ Dealer socket. |
Props |
newDealerSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Java API: Factory method to create the Props to build a ZeroMQ Dealer socket actor. |
ActorRef |
newPubSocket(Bind bind)
Convenience for creating a publisher socket. |
ActorRef |
newPubSocket(SocketOption[] socketParameters)
Java API factory method to create the actor representing the ZeroMQ Publisher socket. |
Props |
newPubSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Java API: Factory method to create the Props to build a ZeroMQ Publisher socket actor. |
ActorRef |
newPullSocket(SocketOption[] socketParameters)
Java API factory method to create the actor representing the ZeroMQ Pull socket. |
Props |
newPullSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Java API: Factory method to create the Props to build a ZeroMQ Pull socket actor. |
ActorRef |
newPushSocket(SocketOption[] socketParameters)
Java API factory method to create the actor representing the ZeroMQ Push socket. |
Props |
newPushSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Java API: Factory method to create the Props to build a ZeroMQ Push socket actor. |
ActorRef |
newRepSocket(SocketOption[] socketParameters)
Java API factory method to create the actor representing the ZeroMQ Rep socket. |
Props |
newRepSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Java API: Factory method to create the Props to build a ZeroMQ Rep socket actor. |
ActorRef |
newReqSocket(SocketOption[] socketParameters)
Java API factory method to create the actor representing the ZeroMQ Req socket. |
Props |
newReqSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Java API: Factory method to create the Props to build a ZeroMQ Req socket actor. |
ActorRef |
newRouterSocket(SocketOption[] socketParameters)
Java API factory method to create the actor representing the ZeroMQ Router socket. |
Props |
newRouterSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Java API: Factory method to create the Props to build a ZeroMQ Router socket actor. |
ActorRef |
newSocket(scala.collection.Seq<SocketOption> socketParameters)
Factory method to create the actor representing the ZeroMQ socket. |
Props |
newSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Factory method to create the Props to build the ZeroMQ socket actor. |
Timeout |
NewSocketTimeout()
|
ActorRef |
newSubSocket(Connect connect,
Listener listener,
Subscribe subscribe)
Convenience for creating a subscriber socket. |
ActorRef |
newSubSocket(SocketOption[] socketParameters)
Java API factory method to create the actor representing the ZeroMQ Subscriber socket. |
Props |
newSubSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Java API: Factory method to create the Props to build a ZeroMQ Subscriber socket actor. |
java.util.concurrent.TimeUnit |
pollTimeUnit()
|
ZeroMQVersion |
version()
The version of the ZeroMQ library |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ZeroMQExtension(ActorSystem system)
Method Detail |
---|
public static ZeroMQExtension get(ActorSystem system)
public static ZeroMQExtension$ lookup()
public static ZeroMQExtension createExtension(ExtendedActorSystem system)
public scala.concurrent.duration.FiniteDuration DefaultPollTimeout()
public Timeout NewSocketTimeout()
public java.util.concurrent.TimeUnit pollTimeUnit()
public ZeroMQVersion version()
ZeroMQVersion
public Props newSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Props
to build the ZeroMQ socket actor.
socketParameters
- a varargs list of SocketOption
to configure the socket
Props
public Props newPubSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Props
to build a ZeroMQ Publisher socket actor.
socketParameters
- a varargs list of SocketOption
to configure the socket
Props
public Props newSubSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Props
to build a ZeroMQ Subscriber socket actor.
socketParameters
- a varargs list of SocketOption
to configure the socket
Props
public Props newDealerSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Props
to build a ZeroMQ Dealer socket actor.
socketParameters
- a varargs list of SocketOption
to configure the socket
Props
public Props newRouterSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Props
to build a ZeroMQ Router socket actor.
socketParameters
- a varargs list of SocketOption
to configure the socket
Props
public Props newPushSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Props
to build a ZeroMQ Push socket actor.
socketParameters
- a varargs list of SocketOption
to configure the socket
Props
public Props newPullSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Props
to build a ZeroMQ Pull socket actor.
socketParameters
- a varargs list of SocketOption
to configure the socket
Props
public Props newReqSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Props
to build a ZeroMQ Req socket actor.
socketParameters
- a varargs list of SocketOption
to configure the socket
Props
public Props newRepSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Props
to build a ZeroMQ Rep socket actor.
socketParameters
- a varargs list of SocketOption
to configure the socket
Props
public ActorRef newSocket(scala.collection.Seq<SocketOption> socketParameters)
socketParameters
- a varargs list of SocketOption
to configure the socke
ActorRef
public ActorRef newPubSocket(SocketOption[] socketParameters)
socketParameters
- array of SocketOption
to configure the socket
ActorRef
public ActorRef newPubSocket(Bind bind)
bind
- (undocumented)
public ActorRef newSubSocket(SocketOption[] socketParameters)
socketParameters
- array of SocketOption
to configure the socket
ActorRef
public ActorRef newSubSocket(Connect connect, Listener listener, Subscribe subscribe)
connect
- (undocumented)listener
- (undocumented)subscribe
- (undocumented)
public ActorRef newDealerSocket(SocketOption[] socketParameters)
socketParameters
- array of SocketOption
to configure the socket
ActorRef
public ActorRef newRouterSocket(SocketOption[] socketParameters)
socketParameters
- array of SocketOption
to configure the socket
ActorRef
public ActorRef newPushSocket(SocketOption[] socketParameters)
socketParameters
- array of SocketOption
to configure the socket
ActorRef
public ActorRef newPullSocket(SocketOption[] socketParameters)
socketParameters
- array of SocketOption
to configure the socket
ActorRef
public ActorRef newReqSocket(SocketOption[] socketParameters)
socketParameters
- array of SocketOption
to configure the socket
ActorRef
public ActorRef newRepSocket(SocketOption[] socketParameters)
socketParameters
- array of SocketOption
to configure the socke
ActorRef
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |