MqttSession.java

Go to the documentation of this file.

package com.navigine.idl.java;
 
import com.navigine.common.NativeObject;
import com.navigine.common.Subscription;

public abstract class MqttSession {
    public abstract void connect(String server, int port, String username, String password);

    public abstract void setSubTopic(String subTopic);

    public abstract void addListener(MqttSessionListener listener);

    public abstract void removeListener(MqttSessionListener listener);

    public abstract void disconnect();

    public abstract void publish(String topic, String message);
}