public class BusClient
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
BusClient.BusClientImplementException |
static class |
BusClient.BusClientRuntimeException |
static interface |
BusClient.Handler |
static class |
BusClient.Multipart |
static class |
BusClient.RPCResult |
static class |
BusClient.XSocket |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DEFAULT_BUS_SERVER |
static int |
DEFAULT_LOGLEVEL |
static java.lang.String |
TAG |
static java.lang.String |
TAG_HIGHFREQ |
Constructor and Description |
---|
BusClient() |
BusClient(java.lang.String names) |
BusClient(java.lang.String names,
int size) |
BusClient(java.lang.String names,
java.lang.String addr,
int sockBufferSize) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<BusClient.RPCResult> |
acall(java.lang.String url,
java.lang.String... args)
Deprecated.
|
BusClient.RPCResult |
call(java.lang.String url) |
BusClient.RPCResult |
call(java.lang.String url,
byte[]... args) |
BusClient.RPCResult |
call(java.lang.String url,
java.util.List<java.lang.String> args) |
BusClient.RPCResult |
call(java.lang.String url,
java.lang.String... args) |
static BusClient.Multipart |
createRemoveStickyTopic(java.lang.String topic)
create a multipart contains a removesticky topic
|
static BusClient.Multipart |
createStickyTopic(java.lang.String topic,
java.lang.String... parts)
create a multipart contains a sticky topic
|
void |
delete() |
void |
dump(java.io.PrintWriter pw) |
void |
interrupt() |
boolean |
isReady() |
void |
killTimer(long id) |
boolean |
publish(BusClient.Multipart multipart) |
void |
publish(java.lang.String topic) |
void |
publish(java.lang.String topic,
byte[]... parts) |
void |
publish(java.lang.String topic,
java.lang.String... parts) |
boolean |
publishSticky(java.lang.String topic,
java.lang.String... parts)
The topic will always be delivered to subscribers
1.
|
boolean |
removeSticky(java.lang.String topic)
The topic will be not sticky anymore
Remove the recent sticky topic kept in memory
|
long |
setTimer(java.lang.Runnable runnable,
long timeout) |
void |
spin(BusClient.Handler handler) |
void |
subscribe(java.lang.String... topics) |
void |
unsubscribe(java.lang.String... topics) |
public static java.lang.String TAG
public static java.lang.String TAG_HIGHFREQ
public static int DEFAULT_LOGLEVEL
public static java.lang.String DEFAULT_BUS_SERVER
public BusClient()
public BusClient(java.lang.String names)
public BusClient(java.lang.String names, int size)
public BusClient(java.lang.String names, java.lang.String addr, int sockBufferSize)
public static BusClient.Multipart createStickyTopic(java.lang.String topic, java.lang.String... parts)
public static BusClient.Multipart createRemoveStickyTopic(java.lang.String topic)
public boolean isReady()
public void delete()
public void subscribe(java.lang.String... topics)
public void unsubscribe(java.lang.String... topics)
public void publish(java.lang.String topic)
public void publish(java.lang.String topic, java.lang.String... parts)
public void publish(java.lang.String topic, byte[]... parts)
public boolean publishSticky(java.lang.String topic, java.lang.String... parts)
topic
- sticky topic to publishparts
- contentpublic boolean removeSticky(java.lang.String topic)
topic
- sticky topic to removepublic boolean publish(BusClient.Multipart multipart)
public BusClient.RPCResult call(java.lang.String url)
public BusClient.RPCResult call(java.lang.String url, java.util.List<java.lang.String> args)
public BusClient.RPCResult call(java.lang.String url, java.lang.String... args)
public BusClient.RPCResult call(java.lang.String url, byte[]... args)
public void dump(java.io.PrintWriter pw)
public void spin(BusClient.Handler handler)
public long setTimer(java.lang.Runnable runnable, long timeout)
public void killTimer(long id)
public void interrupt()
public java.util.concurrent.Future<BusClient.RPCResult> acall(java.lang.String url, java.lang.String... args)