void |
CallbackConnection.connect(Callback<Void> cb) |
void |
CallbackConnection.disconnect(Callback<Void> onComplete) |
void |
CallbackConnection.kill(Callback<Void> onComplete)
Kills the connection without a graceful disconnect.
|
void |
CallbackConnection.publish(String topic,
byte[] payload,
QoS qos,
boolean retain,
Callback<Void> cb) |
void |
CallbackConnection.publish(org.fusesource.hawtbuf.UTF8Buffer topic,
org.fusesource.hawtbuf.Buffer payload,
QoS qos,
boolean retain,
Callback<Void> cb) |
void |
CallbackConnection.subscribe(Topic[] topics,
Callback<byte[]> cb) |
void |
Promise.then(Callback<T> callback) |
void |
Future.then(Callback<T> callback) |
void |
CallbackConnection.unsubscribe(org.fusesource.hawtbuf.UTF8Buffer[] topics,
Callback<Void> cb) |