public class CallbackConnection extends Object
A callback based non/blocking Connection interface to MQTT.
Modifier and Type | Field and Description |
---|---|
static org.fusesource.hawtdispatch.Task |
NOOP |
Constructor and Description |
---|
CallbackConnection(MQTT mqtt) |
Modifier and Type | Method and Description |
---|---|
void |
connect(Callback<Void> cb) |
void |
disconnect(Callback<Void> onComplete) |
Throwable |
failure() |
boolean |
full() |
org.fusesource.hawtdispatch.DispatchQueue |
getDispatchQueue() |
void |
kill(Callback<Void> onComplete)
Kills the connection without a graceful disconnect.
|
CallbackConnection |
listener(Listener listener) |
void |
onSessionEstablished(org.fusesource.hawtdispatch.transport.Transport transport) |
void |
publish(String topic,
byte[] payload,
QoS qos,
boolean retain,
Callback<Void> cb) |
void |
publish(org.fusesource.hawtbuf.UTF8Buffer topic,
org.fusesource.hawtbuf.Buffer payload,
QoS qos,
boolean retain,
Callback<Void> cb) |
CallbackConnection |
refiller(Runnable refiller) |
void |
resume() |
void |
subscribe(Topic[] topics,
Callback<byte[]> cb) |
void |
suspend() |
org.fusesource.hawtdispatch.transport.Transport |
transport() |
void |
unsubscribe(org.fusesource.hawtbuf.UTF8Buffer[] topics,
Callback<Void> cb) |
public CallbackConnection(MQTT mqtt)
public void onSessionEstablished(org.fusesource.hawtdispatch.transport.Transport transport)
public org.fusesource.hawtdispatch.transport.Transport transport()
public org.fusesource.hawtdispatch.DispatchQueue getDispatchQueue()
public void resume()
public void suspend()
public CallbackConnection refiller(Runnable refiller)
public CallbackConnection listener(Listener listener)
public boolean full()
public Throwable failure()
public void kill(Callback<Void> onComplete)
onComplete
- public void publish(String topic, byte[] payload, QoS qos, boolean retain, Callback<Void> cb)
public void publish(org.fusesource.hawtbuf.UTF8Buffer topic, org.fusesource.hawtbuf.Buffer payload, QoS qos, boolean retain, Callback<Void> cb)
Copyright © 2010-2013 FuseSource, Corp.. All Rights Reserved.