MqttSessionBinding.java

Go to the documentation of this file.

package com.navigine.idl.java.internal;
 
import com.navigine.common.NativeObject;
import com.navigine.common.Subscription;
import com.navigine.idl.java.MqttSession;
import com.navigine.idl.java.MqttSessionListener;

public class MqttSessionBinding extends MqttSession
{
    private final NativeObject nativeObject;

    protected MqttSessionBinding(NativeObject nativeObject)
    {
        this.nativeObject = nativeObject;
    }
 
    protected Subscription<MqttSessionListener> weakMqttSessionListenerSubscription = new Subscription<MqttSessionListener>() {
        @Override
        public NativeObject createNativeListener(MqttSessionListener listener) {
            return createMqttSessionListener(listener);
        }
    };
    private static native NativeObject createMqttSessionListener(MqttSessionListener listener);
 
    // MqttSession methods
 
    @Override
    public void connect(String server, int port, String username, String password)
    {
        native_connect(server, port, username, password);
    }
    private native void native_connect(String server, int port, String username, String password);
 
    @Override
    public void setSubTopic(String subTopic)
    {
        native_setSubTopic(subTopic);
    }
    private native void native_setSubTopic(String subTopic);
 
    @Override
    public void addListener(MqttSessionListener listener)
    {
        native_addListener(listener);
    }
    private native void native_addListener(MqttSessionListener listener);
 
    @Override
    public void removeListener(MqttSessionListener listener)
    {
        native_removeListener(listener);
    }
    private native void native_removeListener(MqttSessionListener listener);
 
    @Override
    public void disconnect()
    {
        native_disconnect();
    }
    private native void native_disconnect();
 
    @Override
    public void publish(String topic, String message)
    {
        native_publish(topic, message);
    }
    private native void native_publish(String topic, String message);
}