MqttSessionExample.java

Go to the documentation of this file.

package com.navigine.examples;
 
import com.navigine.idl.java.*;

public class MqttSessionExample {
    private NavigineSdk sdk;
    private LocationManager locationManager;
    private NavigationManager navigationManager;
    private MqttSession mqttSession;
    private MqttSessionListener mqttSessionListener;
 
    public MqttSessionExample() {
        initializeSdk();
        setupMqttSessionListener();
    }

    private void initializeSdk() {
        try {
            // [java_NavigineSdk_getInstance]
            // Get SDK instance
            sdk = NavigineSdk.getInstance();
            // [java_NavigineSdk_getInstance]
 
            // [java_NavigineSdk_setUserHash]
            // Set user hash
            sdk.setUserHash("USER-HASH-HERE");
            // [java_NavigineSdk_setUserHash]
 
            // [java_NavigineSdk_setServer]
            // Set server URL (optional)
            sdk.setServer("https://custom.navigine.com");
            // [java_NavigineSdk_setServer]
 
            // [java_NavigineSdk_getLocationManager]
            // Get LocationManager for working with locations
            locationManager = sdk.getLocationManager();
            // [java_NavigineSdk_getLocationManager]
 
            // [java_NavigineSdk_getNavigationManager]
            // Get NavigationManager for working with navigation
            navigationManager = sdk.getNavigationManager(locationManager);
            // [java_NavigineSdk_getNavigationManager]
 
            // [java_NavigineSdk_getMqttSession]
            // Create MQTT session for publishing position data
            mqttSession = sdk.getMqttSession(navigationManager);
            // [java_NavigineSdk_getMqttSession]
 
            if (mqttSession != null) {
                System.out.println("MqttSession successfully initialized");
            }
        } catch (Exception e) {
            System.err.println("Error initializing SDK: " + e.getMessage());
        }
    }

    private void setupMqttSessionListener() {
        mqttSessionListener = new MqttSessionListener() {
            @Override
            // [java_MqttSessionListener_onConnected]
            public void onConnected() {
                System.out.println("MQTT session connected successfully");
            }
            // [java_MqttSessionListener_onConnected]
 
            @Override
            // [java_MqttSessionListener_onError]
            public void onError(Error error) {
                System.err.println("MQTT session error: " + error.getMessage());
            }
            // [java_MqttSessionListener_onError]
 
            @Override
            // [java_MqttSessionListener_onMessagePublished]
            public void onMessagePublished() {
                System.out.println("Message published successfully");
            }
            // [java_MqttSessionListener_onMessagePublished]
        };
    }

    public void demonstrateMqttSessionMethods() {
        if (mqttSession == null) {
            System.err.println("MqttSession not initialized");
            return;
        }
 
        // [java_MqttSession_addListener]
        // Add MQTT session listener
        mqttSession.addListener(mqttSessionListener);
        // [java_MqttSession_addListener]
 
        // [java_MqttSession_setSubTopic]
        // Set MQTT sub-topic for publishing position data
        // Final topic will be "navigine/mobile/positions/" + subTopic + "/" + deviceId
        mqttSession.setSubTopic("location1");
        // [java_MqttSession_setSubTopic]
 
        // [java_MqttSession_connect]
        // Connect to MQTT broker
        // Server: MQTT broker hostname or IP address
        // Port: MQTT broker port (typically 1883 for non-SSL, 8883 for SSL)
        // Username: MQTT broker username for authentication
        // Password: MQTT broker password for authentication
        mqttSession.connect("mqtt.example.com", 1883, "username", "password");
        // [java_MqttSession_connect]
 
        // Wait for connection
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
 
        // [java_MqttSession_publish]
        // Publish a custom message to a specific MQTT topic
        // The message will be sent asynchronously and the result will be notified through listener callbacks
        String customTopic = "custom/device/status";
        String customMessage = "{\"status\": \"online\", \"timestamp\": " + System.currentTimeMillis() + "}";
        mqttSession.publish(customTopic, customMessage);
        // [java_MqttSession_publish]
    }

    public void demonstrateMqttSessionConfigurations() {
        if (mqttSession == null) {
            System.err.println("MqttSession not initialized");
            return;
        }
 
        System.out.println("=== MQTT Session Configurations ===");
 
        // Example 1: Connect with default port
        // [java_MqttSession_setSubTopic]
        // Set sub-topic. Final topic will be "navigine/mobile/positions/location1/{deviceId}"
        mqttSession.setSubTopic("location1");
        // [java_MqttSession_setSubTopic]
        // [java_MqttSession_connect]
        // Connect to MQTT broker with default port 1883
        mqttSession.connect("mqtt.example.com", 1883, "user", "pass");
        // [java_MqttSession_connect]
 
        // Wait a bit
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
 
        // Disconnect before reconnecting with different config
        // [java_MqttSession_disconnect]
        // Disconnect from MQTT broker
        mqttSession.disconnect();
        // [java_MqttSession_disconnect]
 
        // Example 2: Connect with SSL port
        // [java_MqttSession_setSubTopic]
        // Set sub-topic. Final topic will be "navigine/mobile/positions/building-a/{deviceId}"
        mqttSession.setSubTopic("building-a");
        // [java_MqttSession_setSubTopic]
        // [java_MqttSession_connect]
        // Connect to MQTT broker with SSL port 8883
        mqttSession.connect("mqtt-secure.example.com", 8883, "user", "pass");
        // [java_MqttSession_connect]
 
        // Wait a bit
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
 
        // Example 3: Connect with different sub-topic
        // [java_MqttSession_setSubTopic]
        // Set different sub-topic. Final topic will be "navigine/mobile/positions/floor_2/{deviceId}"
        mqttSession.setSubTopic("floor_2");
        // [java_MqttSession_setSubTopic]
        // [java_MqttSession_connect]
        // Connect to MQTT broker
        mqttSession.connect("mqtt.example.com", 1883, "user", "pass");
        // [java_MqttSession_connect]
    }

    public void demonstrateListenerManagement() {
        if (mqttSession == null) {
            System.err.println("MqttSession not initialized");
            return;
        }
 
        System.out.println("=== Listener Management ===");
 
        // Add multiple listeners
        MqttSessionListener listener1 = new MqttSessionListener() {
            @Override
            public void onConnected() {
                System.out.println("Listener 1: Connected");
            }
 
            @Override
            public void onError(Error error) {
                System.err.println("Listener 1: Error - " + error.getMessage());
            }
 
            @Override
            public void onMessagePublished() {
                System.out.println("Listener 1: Message published");
            }
        };
 
        MqttSessionListener listener2 = new MqttSessionListener() {
            @Override
            public void onConnected() {
                System.out.println("Listener 2: Connected");
            }
 
            @Override
            public void onError(Error error) {
                System.err.println("Listener 2: Error - " + error.getMessage());
            }
 
            @Override
            public void onMessagePublished() {
                System.out.println("Listener 2: Message published");
            }
        };
 
        // [java_MqttSession_addListener]
        // Add first listener
        mqttSession.addListener(listener1);
        // [java_MqttSession_addListener]
 
        // [java_MqttSession_addListener]
        // Add second listener
        mqttSession.addListener(listener2);
        // [java_MqttSession_addListener]
 
        // Connect to trigger callbacks
        // [java_MqttSession_setSubTopic]
        mqttSession.setSubTopic("location1");
        // [java_MqttSession_setSubTopic]
        // [java_MqttSession_connect]
        mqttSession.connect("mqtt.example.com", 1883, "user", "pass");
        // [java_MqttSession_connect]
 
        // Wait for connection
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
 
        // [java_MqttSession_publish]
        // Publish custom messages to different topics
        mqttSession.publish("custom/events", "{\"event\": \"user_action\"}");
        mqttSession.publish("custom/logs", "Application started");
        // [java_MqttSession_publish]
 
        // Wait for messages to be published
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
 
        // [java_MqttSession_removeListener]
        // Remove first listener
        mqttSession.removeListener(listener1);
        // [java_MqttSession_removeListener]
 
        // [java_MqttSession_removeListener]
        // Remove second listener
        mqttSession.removeListener(listener2);
        // [java_MqttSession_removeListener]
    }

    public void cleanup() {
        if (mqttSession != null) {
            // [java_MqttSession_removeListener]
            // Remove MQTT session listener
            if (mqttSessionListener != null) {
                mqttSession.removeListener(mqttSessionListener);
            }
            // [java_MqttSession_removeListener]
 
            // [java_MqttSession_disconnect]
            // Disconnect from MQTT broker
            mqttSession.disconnect();
            // [java_MqttSession_disconnect]
        }
    }

    public void runExample() {
        System.out.println("=== MqttSession Example ===");
 
        demonstrateMqttSessionMethods();
        demonstrateMqttSessionConfigurations();
        demonstrateListenerManagement();
 
        // Wait a bit for connection events
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
 
        cleanup();
        System.out.println("=== Example completed ===");
    }

    public static void main(String[] args) {
        MqttSessionExample example = new MqttSessionExample();
        example.runExample();
    }
}