akka.zeromq
Class ZeroMQExtension

java.lang.Object
  extended by akka.zeromq.ZeroMQExtension
All Implemented Interfaces:
Extension

public class ZeroMQExtension
extends java.lang.Object
implements Extension

The extension for the ZeroMQ module


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

ZeroMQExtension

public ZeroMQExtension(ActorSystem system)
Method Detail

get

public static ZeroMQExtension get(ActorSystem system)

lookup

public static ZeroMQExtension$ lookup()

createExtension

public static ZeroMQExtension createExtension(ExtendedActorSystem system)

DefaultPollTimeout

public scala.concurrent.duration.FiniteDuration DefaultPollTimeout()

NewSocketTimeout

public Timeout NewSocketTimeout()

pollTimeUnit

public java.util.concurrent.TimeUnit pollTimeUnit()

version

public ZeroMQVersion version()
The version of the ZeroMQ library

Returns:
a ZeroMQVersion

newSocketProps

public Props newSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Factory method to create the Props to build the ZeroMQ socket actor.

Parameters:
socketParameters - a varargs list of SocketOption to configure the socket
Returns:
the Props

newPubSocketProps

public Props newPubSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Java API: Factory method to create the Props to build a ZeroMQ Publisher socket actor.

Parameters:
socketParameters - a varargs list of SocketOption to configure the socket
Returns:
the Props

newSubSocketProps

public Props newSubSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Java API: Factory method to create the Props to build a ZeroMQ Subscriber socket actor.

Parameters:
socketParameters - a varargs list of SocketOption to configure the socket
Returns:
the Props

newDealerSocketProps

public Props newDealerSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Java API: Factory method to create the Props to build a ZeroMQ Dealer socket actor.

Parameters:
socketParameters - a varargs list of SocketOption to configure the socket
Returns:
the Props

newRouterSocketProps

public Props newRouterSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Java API: Factory method to create the Props to build a ZeroMQ Router socket actor.

Parameters:
socketParameters - a varargs list of SocketOption to configure the socket
Returns:
the Props

newPushSocketProps

public Props newPushSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Java API: Factory method to create the Props to build a ZeroMQ Push socket actor.

Parameters:
socketParameters - a varargs list of SocketOption to configure the socket
Returns:
the Props

newPullSocketProps

public Props newPullSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Java API: Factory method to create the Props to build a ZeroMQ Pull socket actor.

Parameters:
socketParameters - a varargs list of SocketOption to configure the socket
Returns:
the Props

newReqSocketProps

public Props newReqSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Java API: Factory method to create the Props to build a ZeroMQ Req socket actor.

Parameters:
socketParameters - a varargs list of SocketOption to configure the socket
Returns:
the Props

newRepSocketProps

public Props newRepSocketProps(scala.collection.Seq<SocketOption> socketParameters)
Java API: Factory method to create the Props to build a ZeroMQ Rep socket actor.

Parameters:
socketParameters - a varargs list of SocketOption to configure the socket
Returns:
the Props

newSocket

public ActorRef newSocket(scala.collection.Seq<SocketOption> socketParameters)
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.

Parameters:
socketParameters - a varargs list of SocketOption to configure the socke
Returns:
the ActorRef

newPubSocket

public ActorRef newPubSocket(SocketOption[] socketParameters)
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.

Parameters:
socketParameters - array of SocketOption to configure the socket
Returns:
the ActorRef

newPubSocket

public ActorRef newPubSocket(Bind bind)
Convenience for creating a publisher socket.


newSubSocket

public ActorRef newSubSocket(SocketOption[] socketParameters)
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.

Parameters:
socketParameters - array of SocketOption to configure the socket
Returns:
the ActorRef

newSubSocket

public ActorRef newSubSocket(Connect connect,
                             Listener listener,
                             Subscribe subscribe)
Convenience for creating a subscriber socket.


newDealerSocket

public ActorRef newDealerSocket(SocketOption[] socketParameters)
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.

Parameters:
socketParameters - array of SocketOption to configure the socket
Returns:
the ActorRef

newRouterSocket

public ActorRef newRouterSocket(SocketOption[] socketParameters)
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.

Parameters:
socketParameters - array of SocketOption to configure the socket
Returns:
the ActorRef

newPushSocket

public ActorRef newPushSocket(SocketOption[] socketParameters)
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.

Parameters:
socketParameters - array of SocketOption to configure the socket
Returns:
the ActorRef

newPullSocket

public ActorRef newPullSocket(SocketOption[] socketParameters)
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.

Parameters:
socketParameters - array of SocketOption to configure the socket
Returns:
the ActorRef

newReqSocket

public ActorRef newReqSocket(SocketOption[] socketParameters)
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.

Parameters:
socketParameters - array of SocketOption to configure the socket
Returns:
the ActorRef

newRepSocket

public ActorRef newRepSocket(SocketOption[] socketParameters)
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.

Parameters:
socketParameters - array of SocketOption to configure the socke
Returns:
the ActorRef