org.zeromq.jzmq.clone

Class CloneClientImpl

java.lang.Object

org.zeromq.jzmq.clone.CloneClientImpl

All Implemented Interfaces:

CloneClient

public class CloneClientImpl
extends Object
implements CloneClient

Constructor Summary

Constructors

Constructor and Description
CloneClientImpl(ManagedContext context, long heartbeatInterval)

Method Summary

Modifier and Type	Method and Description
void	close() Destroy this client.
void	connect(String address, int port) Connect to a new server endpoint.
String	get(String key) Look up the value in the shared hashmap.
Map<String,String>	getAll() Look up all values in the shared hashmap.
void	set(String key, String value) Set a new value in the shared hashmap, with no ttl.
void	set(String key, String value, long ttl) Set a new value in the shared hashmap.
void	subscribe(String subtree) Specify subtree for snapshot and updates.

Methods inherited from class java.lang.Object

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

Constructor Detail

CloneClientImpl

public CloneClientImpl(ManagedContext context,
                       long heartbeatInterval)

Method Detail

subscribe

public void subscribe(String subtree)

Description copied from interface: CloneClient

Specify subtree for snapshot and updates.

Note: We must do this before connecting to a server as the subtree specification is sent as the first command to the server.

Specified by:

subscribe in interface CloneClient

Parameters:

subtree - The prefix (subtree) to subscribe to

connect

public void connect(String address,
                    int port)

Description copied from interface: CloneClient

Connect to a new server endpoint. We can connect to at most two servers.

Specified by:

connect in interface CloneClient

Parameters:

address - The address of the server to connect to

port - The port on the server to connect to

set

public void set(String key,
                String value)

Description copied from interface: CloneClient

Set a new value in the shared hashmap, with no ttl.

Specified by:

set in interface CloneClient

Parameters:

key - The key associated with the new value

value - The new value to set in the shared hashmap

set

public void set(String key,
                String value,
                long ttl)

Description copied from interface: CloneClient

Set a new value in the shared hashmap.

Specified by:

set in interface CloneClient

Parameters:

key - The key associated with the new value

value - The new value to set in the shared hashmap

ttl - The time-to-live for the given value, in seconds

get

public String get(String key)

Description copied from interface: CloneClient

Look up the value in the shared hashmap.

Specified by:

get in interface CloneClient

Parameters:

key - The key to look up

Returns:

The value associated with the given key, or null

getAll

public Map<String,String> getAll()

Description copied from interface: CloneClient

Look up all values in the shared hashmap.

Specified by:

getAll in interface CloneClient

Returns:

The entire map

close

public void close()

Description copied from interface: CloneClient

Destroy this client.

Specified by:

close in interface CloneClient