akka.zeromq
Class ZeroMQExtension

java.lang.Object
  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