MqttSessionExample.kt

Go to the documentation of this file.

package com.navigine.examples
 
import com.navigine.idl.java.*
 
/**
 * MqttSession usage example for Kotlin
 * Demonstrates working with MQTT session for publishing position data
 */
class MqttSessionExample {
    private var sdk: NavigineSdk? = null
    private var locationManager: LocationManager? = null
    private var navigationManager: NavigationManager? = null
    private var mqttSession: MqttSession? = null
    private var mqttSessionListener: MqttSessionListener? = null
 
    init {
        initializeSdk()
        setupMqttSessionListener()
    }
 
    /**
     * Initialize SDK and get managers
     */
    private fun initializeSdk() {
        try {
            // [kotlin_NavigineSdk_getInstance]
            // Get SDK instance
            sdk = NavigineSdk.getInstance()
            // [kotlin_NavigineSdk_getInstance]
 
            // [kotlin_NavigineSdk_setUserHash]
            // Set user hash
            sdk?.setUserHash("USER-HASH-HERE")
            // [kotlin_NavigineSdk_setUserHash]
 
            // [kotlin_NavigineSdk_setServer]
            // Set server URL (optional)
            sdk?.setServer("https://custom.navigine.com")
            // [kotlin_NavigineSdk_setServer]
 
            // [kotlin_NavigineSdk_getLocationManager]
            // Get LocationManager for working with locations
            locationManager = sdk?.getLocationManager()
            // [kotlin_NavigineSdk_getLocationManager]
 
            // [kotlin_NavigineSdk_getNavigationManager]
            // Get NavigationManager for working with navigation
            navigationManager = sdk?.getNavigationManager(locationManager)
            // [kotlin_NavigineSdk_getNavigationManager]
 
            // [kotlin_NavigineSdk_getMqttSession]
            // Create MQTT session for publishing position data
            mqttSession = sdk?.getMqttSession(navigationManager)
            // [kotlin_NavigineSdk_getMqttSession]
 
            if (mqttSession != null) {
                println("MqttSession successfully initialized")
            }
        } catch (e: Exception) {
            System.err.println("Error initializing SDK: ${e.message}")
        }
    }
 
    /**
     * Setup MQTT session listener
     */
    private fun setupMqttSessionListener() {
        mqttSessionListener = object : MqttSessionListener() {
            // [kotlin_MqttSessionListener_onConnected]
            override fun onConnected() {
                println("MQTT session connected successfully")
            }
            // [kotlin_MqttSessionListener_onConnected]
 
            // [kotlin_MqttSessionListener_onError]
            override fun onError(error: Error) {
                System.err.println("MQTT session error: ${error.message}")
            }
            // [kotlin_MqttSessionListener_onError]
 
            // [kotlin_MqttSessionListener_onMessagePublished]
            override fun onMessagePublished() {
                println("Message published successfully")
            }
            // [kotlin_MqttSessionListener_onMessagePublished]
        }
    }
 
    /**
     * Demonstrate MqttSession methods
     */
    fun demonstrateMqttSessionMethods() {
        val session = mqttSession ?: run {
            System.err.println("MqttSession not initialized")
            return
        }
 
        val listener = mqttSessionListener ?: return
 
        // [kotlin_MqttSession_addListener]
        // Add MQTT session listener
        session.addListener(listener)
        // [kotlin_MqttSession_addListener]
 
        // [kotlin_MqttSession_setSubTopic]
        // Set MQTT sub-topic for publishing position data
        // Final topic will be "navigine/mobile/positions/" + subTopic + "/" + deviceId
        session.setSubTopic("location1")
        // [kotlin_MqttSession_setSubTopic]
 
        // [kotlin_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
        session.connect("mqtt.example.com", 1883, "username", "password")
        // [kotlin_MqttSession_connect]
 
        // Wait for connection
        Thread.sleep(2000)
 
        // [kotlin_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
        val customTopic = "custom/device/status"
        val customMessage = """{"status": "online", "timestamp": ${System.currentTimeMillis()}}"""
        session.publish(customTopic, customMessage)
        // [kotlin_MqttSession_publish]
    }
 
    /**
     * Demonstrate MQTT session with different configurations
     */
    fun demonstrateMqttSessionConfigurations() {
        val session = mqttSession ?: run {
            System.err.println("MqttSession not initialized")
            return
        }
 
        println("=== MQTT Session Configurations ===")
 
        // Example 1: Connect with default port
        // [kotlin_MqttSession_setSubTopic]
        // Set sub-topic. Final topic will be "navigine/mobile/positions/location1/{deviceId}"
        session.setSubTopic("location1")
        // [kotlin_MqttSession_setSubTopic]
        // [kotlin_MqttSession_connect]
        // Connect to MQTT broker with default port 1883
        session.connect("mqtt.example.com", 1883, "user", "pass")
        // [kotlin_MqttSession_connect]
 
        // Wait a bit
        Thread.sleep(1000)
 
        // Disconnect before reconnecting with different config
        // [kotlin_MqttSession_disconnect]
        // Disconnect from MQTT broker
        session.disconnect()
        // [kotlin_MqttSession_disconnect]
 
        // Example 2: Connect with SSL port
        // [kotlin_MqttSession_setSubTopic]
        // Set sub-topic. Final topic will be "navigine/mobile/positions/building-a/{deviceId}"
        session.setSubTopic("building-a")
        // [kotlin_MqttSession_setSubTopic]
        // [kotlin_MqttSession_connect]
        // Connect to MQTT broker with SSL port 8883
        session.connect("mqtt-secure.example.com", 8883, "user", "pass")
        // [kotlin_MqttSession_connect]
 
        // Wait a bit
        Thread.sleep(1000)
 
        // Example 3: Connect with different sub-topic
        // [kotlin_MqttSession_setSubTopic]
        // Set different sub-topic. Final topic will be "navigine/mobile/positions/floor_2/{deviceId}"
        session.setSubTopic("floor_2")
        // [kotlin_MqttSession_setSubTopic]
        // [kotlin_MqttSession_connect]
        // Connect to MQTT broker
        session.connect("mqtt.example.com", 1883, "user", "pass")
        // [kotlin_MqttSession_connect]
    }
 
    /**
     * Demonstrate listener management
     */
    fun demonstrateListenerManagement() {
        val session = mqttSession ?: run {
            System.err.println("MqttSession not initialized")
            return
        }
 
        println("=== Listener Management ===")
 
        // Add multiple listeners
        val listener1 = object : MqttSessionListener() {
            override fun onConnected() {
                println("Listener 1: Connected")
            }
 
            override fun onError(error: Error) {
                System.err.println("Listener 1: Error - ${error.message}")
            }
 
            override fun onMessagePublished() {
                println("Listener 1: Message published")
            }
        }
 
        val listener2 = object : MqttSessionListener() {
            override fun onConnected() {
                println("Listener 2: Connected")
            }
 
            override fun onError(error: Error) {
                System.err.println("Listener 2: Error - ${error.message}")
            }
 
            override fun onMessagePublished() {
                println("Listener 2: Message published")
            }
        }
 
        // [kotlin_MqttSession_addListener]
        // Add first listener
        session.addListener(listener1)
        // [kotlin_MqttSession_addListener]
 
        // [kotlin_MqttSession_addListener]
        // Add second listener
        session.addListener(listener2)
        // [kotlin_MqttSession_addListener]
 
        // Connect to trigger callbacks
        // [kotlin_MqttSession_setSubTopic]
        session.setSubTopic("location1")
        // [kotlin_MqttSession_setSubTopic]
        // [kotlin_MqttSession_connect]
        session.connect("mqtt.example.com", 1883, "user", "pass")
        // [kotlin_MqttSession_connect]
 
        // Wait for connection
        Thread.sleep(2000)
 
        // [kotlin_MqttSession_publish]
        // Publish custom messages to different topics
        session.publish("custom/events", """{"event": "user_action"}""")
        session.publish("custom/logs", "Application started")
        // [kotlin_MqttSession_publish]
 
        // Wait for messages to be published
        Thread.sleep(1000)
 
        // [kotlin_MqttSession_removeListener]
        // Remove first listener
        session.removeListener(listener1)
        // [kotlin_MqttSession_removeListener]
 
        // [kotlin_MqttSession_removeListener]
        // Remove second listener
        session.removeListener(listener2)
        // [kotlin_MqttSession_removeListener]
    }
 
    /**
     * Clean up resources
     */
    fun cleanup() {
        mqttSession?.let { session ->
            // [kotlin_MqttSession_removeListener]
            // Remove MQTT session listener
            mqttSessionListener?.let { listener ->
                session.removeListener(listener)
            }
            // [kotlin_MqttSession_removeListener]
 
            // [kotlin_MqttSession_disconnect]
            // Disconnect from MQTT broker
            session.disconnect()
            // [kotlin_MqttSession_disconnect]
        }
    }
 
    /**
     * Main demonstration method
     */
    fun runExample() {
        println("=== MqttSession Example ===")
 
        demonstrateMqttSessionMethods()
        demonstrateMqttSessionConfigurations()
        demonstrateListenerManagement()
 
        // Wait a bit for connection events
        Thread.sleep(3000)
 
        cleanup()
        println("=== Example completed ===")
    }
}
 
/**
 * Function to run the example
 */
fun main() {
    val example = MqttSessionExample()
    example.runExample()
}