public class BusClient
extends java.lang.Object
限定符和类型 | 类和说明 |
---|---|
static class |
BusClient.BusClientImplementException |
static class |
BusClient.BusClientRuntimeException |
static interface |
BusClient.Handler |
static class |
BusClient.Multipart |
static class |
BusClient.RPCResult |
static class |
BusClient.XSocket |
限定符和类型 | 字段和说明 |
---|---|
static java.lang.String |
DEFAULT_BUS_SERVER |
static int |
DEFAULT_LOGLEVEL |
static java.lang.String |
TAG |
static java.lang.String |
TAG_HIGHFREQ |
构造器和说明 |
---|
BusClient() |
BusClient(java.lang.String names) |
BusClient(java.lang.String names,
int size) |
BusClient(java.lang.String names,
java.lang.String addr,
int sockBufferSize) |
限定符和类型 | 方法和说明 |
---|---|
java.util.concurrent.Future<BusClient.RPCResult> |
acall(java.lang.String url,
java.lang.String... args)
已过时。
|
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. no matter aios has ready or not.
2. no matter subscriber invokes bc.subscribe earlier or later.
|
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)