Future<Void> |
FutureConnection.connect() |
Future<Void> |
FutureConnection.disconnect() |
Future<Void> |
FutureConnection.kill() |
Future<Void> |
FutureConnection.publish(String topic,
byte[] payload,
QoS qos,
boolean retain) |
Future<Void> |
FutureConnection.publish(org.fusesource.hawtbuf.UTF8Buffer topic,
org.fusesource.hawtbuf.Buffer payload,
QoS qos,
boolean retain) |
Future<Message> |
FutureConnection.receive() |
Future<byte[]> |
FutureConnection.subscribe(Topic[] topics) |
Future<Void> |
FutureConnection.unsubscribe(String[] topics) |
Future<Void> |
FutureConnection.unsubscribe(org.fusesource.hawtbuf.UTF8Buffer[] topics) |