public class BlockingConnection extends Object
A blocking Connection interface to MQTT.
Constructor and Description |
---|
BlockingConnection(FutureConnection next) |
Modifier and Type | Method and Description |
---|---|
protected Object |
clone() |
void |
connect() |
void |
disconnect() |
boolean |
isConnected() |
void |
kill() |
void |
publish(String topic,
byte[] payload,
QoS qos,
boolean retain) |
void |
publish(org.fusesource.hawtbuf.UTF8Buffer topic,
org.fusesource.hawtbuf.Buffer payload,
QoS qos,
boolean retain) |
Message |
receive() |
Message |
receive(long amount,
TimeUnit unit) |
void |
resume() |
byte[] |
subscribe(Topic[] topics) |
void |
suspend() |
void |
unsubscribe(String[] topics) |
void |
unsubscribe(org.fusesource.hawtbuf.UTF8Buffer[] topics) |
public BlockingConnection(FutureConnection next)
public boolean isConnected()
public void unsubscribe(org.fusesource.hawtbuf.UTF8Buffer[] topics) throws Exception
Exception
public void publish(org.fusesource.hawtbuf.UTF8Buffer topic, org.fusesource.hawtbuf.Buffer payload, QoS qos, boolean retain) throws Exception
Exception
protected Object clone() throws CloneNotSupportedException
clone
in class Object
CloneNotSupportedException
public void publish(String topic, byte[] payload, QoS qos, boolean retain) throws Exception
Exception
public Message receive(long amount, TimeUnit unit) throws Exception
Exception
public void resume()
public void suspend()
Copyright © 2010–2015 FuseSource, Corp.. All rights reserved.