org.zeromq

Class Patterns

java.lang.Object

org.zeromq.Patterns

public class Patterns
extends Object

Class containing utility methods for creating objects for different patterns without using a ØMQ Context directly.

Method Summary

Modifier and Type	Method and Description
static BeaconReactorBuilder	buildBeaconReactor() Create a new BeaconReactor, which will send and receive UDP beacons on a broadcast address, with event-driven handling of received beacons.
static BinaryStarReactorBuilder	buildBinaryStarReactor() Create a new BinaryStarReactor, which will create one half of an HA-pair with event-driven polling of a client Socket.
static BinaryStarSocketBuilder	buildBinaryStarSocket() Create a ØMQ Socket, backed by a background agent that is connecting to a BinaryStarReactor HA-pair.
static CloneClientBuilder	buildCloneClient() Create a new CloneClient, connected to an HA-pair, for publishing key/value data to anonymous peers.
static CloneServerBuilder	buildCloneServer() Create a new CloneServer, which will create one half of an HA-pair for distributing key/value data to clients.
static Socket	newBinaryStarSocket(String primaryUrl, String backupUrl) Create a ØMQ DEALER Socket, backed by a background agent that is connected to a BinaryStarReactor HA-pair.
static CloneClient	newCloneClient(String primaryAddress, String backupAddress, String subtree) Create a new CloneClient, connected to an HA-pair, for publishing key/value data to anonymous peers.
static CloneServer	newCloneServer(BinaryStarReactor.Mode mode, String primaryAddress, String backupAddress) Create a new CloneServer, which will create one half of an HA-pair for distributing key/value data to clients.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

buildBinaryStarReactor

public static BinaryStarReactorBuilder buildBinaryStarReactor()

Create a new BinaryStarReactor, which will create one half of an HA-pair with event-driven polling of a client Socket.

Returns:

A builder for constructing a BinaryStarReactor

buildBinaryStarSocket

public static BinaryStarSocketBuilder buildBinaryStarSocket()

Create a ØMQ Socket, backed by a background agent that is connecting to a BinaryStarReactor HA-pair.

Returns:

A builder for constructing connecting a BinaryStarReactor client Socket

newBinaryStarSocket

public static Socket newBinaryStarSocket(String primaryUrl,
                                         String backupUrl)

Create a ØMQ DEALER Socket, backed by a background agent that is connected to a BinaryStarReactor HA-pair.

Parameters:

primaryUrl - The primary server's url to connect to

backupUrl - The backup server's url to connect to

Returns:

A new Socket connected to an HA-pair

buildCloneServer

public static CloneServerBuilder buildCloneServer()

Create a new CloneServer, which will create one half of an HA-pair for distributing key/value data to clients.

Returns:

A builder for constructing a CloneServer

newCloneServer

public static CloneServer newCloneServer(BinaryStarReactor.Mode mode,
                                         String primaryAddress,
                                         String backupAddress)

Create a new CloneServer, which will create one half of an HA-pair for distributing key/value data to clients.

Parameters:

mode - The server mode (e.g. PRIMARY, BACKUP)

primaryAddress - The primary server's url to connect to (if mode is BACKUP)

backupAddress - The backup server's url to connect to (if mode is PRIMARY)

Returns:

A new CloneServer

buildCloneClient

public static CloneClientBuilder buildCloneClient()

Create a new CloneClient, connected to an HA-pair, for publishing key/value data to anonymous peers.

Returns:

A builder for constructing a CloneClient

newCloneClient

public static CloneClient newCloneClient(String primaryAddress,
                                         String backupAddress,
                                         String subtree)

Create a new CloneClient, connected to an HA-pair, for publishing key/value data to anonymous peers.

Parameters:

primaryAddress - The primary server's url to connect to

backupAddress - The backup server's url to connect to

subtree - The prefix (subtree) to subscribe to

Returns:

A new CloneClient

buildBeaconReactor

public static BeaconReactorBuilder buildBeaconReactor()

Create a new BeaconReactor, which will send and receive UDP beacons on a broadcast address, with event-driven handling of received beacons.

Returns:

A builder for constructing a BeaconReactor