MqttSession.java

Go to the documentation of this file.

package com.navigine.idl.java;
 
import java.util.concurrent.atomic.AtomicBoolean;

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);
 
    private static final class CppProxy extends MqttSession
    {
        private final long nativeRef;
        private final AtomicBoolean destroyed = new AtomicBoolean(false);
 
        private CppProxy(long nativeRef)
        {
            if (nativeRef == 0) throw new RuntimeException("nativeRef is zero");
            this.nativeRef = nativeRef;
        }
 
        private native void nativeDestroy(long nativeRef);
        public void _djinni_private_destroy()
        {
            boolean destroyed = this.destroyed.getAndSet(true);
            if (!destroyed) nativeDestroy(this.nativeRef);
        }
        protected void finalize() throws java.lang.Throwable
        {
            _djinni_private_destroy();
            super.finalize();
        }
 
        // MqttSession methods
 
        @Override
        public void connect(String server, int port, String username, String password)
        {
            assert !this.destroyed.get() : "trying to use a destroyed object";
            native_connect(this.nativeRef, server, port, username, password);
        }
        private native void native_connect(long _nativeRef, String server, int port, String username, String password);
 
        @Override
        public void setSubTopic(String subTopic)
        {
            assert !this.destroyed.get() : "trying to use a destroyed object";
            native_setSubTopic(this.nativeRef, subTopic);
        }
        private native void native_setSubTopic(long _nativeRef, String subTopic);
 
        @Override
        public void addListener(MqttSessionListener listener)
        {
            assert !this.destroyed.get() : "trying to use a destroyed object";
            native_addListener(this.nativeRef, listener);
        }
        private native void native_addListener(long _nativeRef, MqttSessionListener listener);
 
        @Override
        public void removeListener(MqttSessionListener listener)
        {
            assert !this.destroyed.get() : "trying to use a destroyed object";
            native_removeListener(this.nativeRef, listener);
        }
        private native void native_removeListener(long _nativeRef, MqttSessionListener listener);
 
        @Override
        public void disconnect()
        {
            assert !this.destroyed.get() : "trying to use a destroyed object";
            native_disconnect(this.nativeRef);
        }
        private native void native_disconnect(long _nativeRef);
 
        @Override
        public void publish(String topic, String message)
        {
            assert !this.destroyed.get() : "trying to use a destroyed object";
            native_publish(this.nativeRef, topic, message);
        }
        private native void native_publish(long _nativeRef, String topic, String message);
    }
}