org.fusesource.mqtt.client

Class BlockingConnection

java.lang.Object

org.fusesource.mqtt.client.BlockingConnection

public class BlockingConnection
extends Object

A blocking Connection interface to MQTT.

Author:

Hiram Chirino

Constructor Summary

Constructors

Constructor and Description
BlockingConnection(FutureConnection next)

Method Summary

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)

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BlockingConnection

public BlockingConnection(FutureConnection next)

Method Detail

isConnected

public boolean isConnected()

connect

public void connect()
             throws Exception

Throws:

Exception

disconnect

public void disconnect()
                throws Exception

Throws:

Exception

kill

public void kill()
          throws Exception

Throws:

Exception

subscribe

public byte[] subscribe(Topic[] topics)
                 throws Exception

Throws:

Exception

unsubscribe

public void unsubscribe(String[] topics)
                 throws Exception

Throws:

Exception

unsubscribe

public void unsubscribe(org.fusesource.hawtbuf.UTF8Buffer[] topics)
                 throws Exception

Throws:

Exception

publish

public void publish(org.fusesource.hawtbuf.UTF8Buffer topic,
                    org.fusesource.hawtbuf.Buffer payload,
                    QoS qos,
                    boolean retain)
             throws Exception

Throws:

Exception

clone

protected Object clone()
                throws CloneNotSupportedException

Overrides:

clone in class Object

Throws:

CloneNotSupportedException

publish

public void publish(String topic,
                    byte[] payload,
                    QoS qos,
                    boolean retain)
             throws Exception

Throws:

Exception

receive

public Message receive()
                throws Exception

Throws:

Exception

receive

public Message receive(long amount,
                       TimeUnit unit)
                throws Exception

Returns:

null if the receive times out.

Throws:

Exception

resume

public void resume()

suspend

public void suspend()