public class FutureConnection extends Object
A Future based optionally-blocking Connection interface to MQTT.
Constructor and Description |
---|
FutureConnection(CallbackConnection next) |
Modifier and Type | Method and Description |
---|---|
Future<Void> |
connect() |
Future<Void> |
disconnect() |
boolean |
isConnected() |
Future<Void> |
kill() |
Future<Void> |
publish(String topic,
byte[] payload,
QoS qos,
boolean retain) |
Future<Void> |
publish(org.fusesource.hawtbuf.UTF8Buffer topic,
org.fusesource.hawtbuf.Buffer payload,
QoS qos,
boolean retain) |
Future<Message> |
receive() |
void |
resume() |
Future<byte[]> |
subscribe(Topic[] topics) |
void |
suspend() |
Future<Void> |
unsubscribe(String[] topics) |
Future<Void> |
unsubscribe(org.fusesource.hawtbuf.UTF8Buffer[] topics) |
public FutureConnection(CallbackConnection next)
Copyright © 2010–2014 FuseSource, Corp.. All rights reserved.