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() |
org.fusesource.hawtdispatch.DispatchQueue |
getDispatchQueue() |
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)
public boolean isConnected()
public org.fusesource.hawtdispatch.DispatchQueue getDispatchQueue()
public Future<Void> publish(org.fusesource.hawtbuf.UTF8Buffer topic, org.fusesource.hawtbuf.Buffer payload, QoS qos, boolean retain)
public void resume()
public void suspend()
Copyright © 2010–2017 FuseSource, Corp.. All rights reserved.