public interface  org.fusesource.mqtt.client.Future extends java.lang.Object
{
public abstract java.lang.Object await() throws java.lang.Exception;
public abstract java.lang.Object await(long, java.util.concurrent.TimeUnit) throws java.lang.Exception;
public abstract void then(org.fusesource.mqtt.client.Callback);
}