RTI Routing Service MQTT Adapter Logo

Contents

  • 1. Introduction
  • 2. Configuration
    • 2.1. Load the MQTT Adapter Plugin
    • 2.2. Register MQTT Data Types
    • 2.3. Configure QoS
    • 2.4. Connect to an MQTT Broker
    • 2.5. Route Data from MQTT to DDS
    • 2.6. Route Data from DDS to MQTT
    • 2.7. XML Configuration properties
      • 2.7.1. <connection> Properties
        • 2.7.1.1. client.id
        • 2.7.1.2. client.servers
        • 2.7.1.3. client.protocol_version
        • 2.7.1.4. client.connection_timeout.sec
        • 2.7.1.5. client.connection_timeout.nanosec
        • 2.7.1.6. client.max_connection_retries
        • 2.7.1.7. client.keep_alive_period.sec
        • 2.7.1.8. client.keep_alive_period.nanosec
        • 2.7.1.9. client.clean_session
        • 2.7.1.10. client.unsubscribe_on_disconnect
        • 2.7.1.11. client.max_reply_timeout.sec
        • 2.7.1.12. client.max_reply_timeout.nanosec
        • 2.7.1.13. client.reconnect
        • 2.7.1.14. client.max_unack_messages
        • 2.7.1.15. client.persistence
        • 2.7.1.16. client.persistence_storage
        • 2.7.1.17. client.username
        • 2.7.1.18. client.password
        • 2.7.1.19. client.ssl.ca
        • 2.7.1.20. client.ssl.id
        • 2.7.1.21. client.ssl.key
        • 2.7.1.22. client.ssl.key_password
        • 2.7.1.23. client.ssl.protocol_version
        • 2.7.1.24. client.ssl.verify_server_certificate
        • 2.7.1.25. client.ssl.cypher_suites
      • 2.7.2. <input> Properties
        • 2.7.2.1. subscription.topics
        • 2.7.2.2. subscription.max_qos
        • 2.7.2.3. subscription.queue_size
      • 2.7.3. <output> Properties
        • 2.7.3.1. publication.topic
        • 2.7.3.2. publication.qos
        • 2.7.3.3. publication.retained
        • 2.7.3.4. publication.use_message_info
        • 2.7.3.5. publication.max_wait_time.sec
        • 2.7.3.6. publication.max_wait_time.nanosec
  • 3. MQTT Adapter API
    • 3.1. Compiler Defines
      • 3.1.1. User Defines
        • RTI_MQTT_PLATFORM
        • RTI_MQTT_ENABLE_SSL
        • RTI_MQTT_STATIC_TYPES
        • RTI_MQTT_ENABLE_LOG
        • RTI_MQTT_DISABLE_LOG
        • RTI_MQTT_ENABLE_TRACE
        • MQTT_CLIENT_API
      • 3.1.2. Automatic Defines
        • RTI_MQTT_USE_SSL
        • RTI_MQTT_USE_STATIC_TYPES
        • RTI_MQTT_USE_LOG
        • RTI_MQTT_USE_TRACE
        • RTI_MQTT_DYNAMIC_TYPES
      • 3.1.3. Platform Defines
        • RTI_MQTT_PLATFORM_UNKNOWN
        • RTI_MQTT_PLATFORM_POSIX
        • RTI_MQTT_PLATFORM_WINDOWS
      • 3.1.4. MQTT Library Defines
        • MQTT_CLIENT_API_PAHO_C
        • MQTT_CLIENT_API_MOSQUITTO
        • MQTT_CLIENT_API_DEFAULT
    • 3.2. MQTT Client API
      • 3.2.1. MQTT Configuration
        • 3.2.1.1. MQTT Client Configuration
        • 3.2.1.2. MQTT Subscription Configuration
        • 3.2.1.3. MQTT Publication Configuration
        • 3.2.1.4. Configuration Infrastructure
      • 3.2.2. MQTT Client
        • RTI_MQTT_Client_new()
        • RTI_MQTT_Client_delete()
        • RTI_MQTT_Client_connect()
        • RTI_MQTT_Client_disconnect()
        • RTI_MQTT_Client_subscribe()
        • RTI_MQTT_Client_unsubscribe()
        • RTI_MQTT_Client_publish()
        • RTI_MQTT_Client_unpublish()
        • RTI_MQTT_Client_get_id()
      • 3.2.3. MQTT Subscription
        • RTI_MQTT_SUBSCRIPTION_READ_LENGTH_UNLIMITED
        • RTI_MQTT_Subscription_DataAvailableCallback
        • RTI_MQTT_Subscription_set_data_available_listener()
        • RTI_MQTT_Subscription_read()
        • RTI_MQTT_Subscription_return_loan()
      • 3.2.4. MQTT Publication
        • RTI_MQTT_Publication_write()
        • RTI_MQTT_Publication_write_w_params()
      • 3.2.5. MQTT Message
        • RTI_MQTT_Message_to_dynamic_data()
        • RTI_MQTT_Message_from_dynamic_data()
      • 3.2.6. Platform Support
        • RTI_MQTT_MUTEX_POSIX
        • RTI_MQTT_MUTEX_INITIALIZER_POSIX
        • RTI_MQTT_MUTEX_WINDOWS
        • RTI_MQTT_MUTEX_INITIALIZER_WINDOWS
        • RTI_MQTT_MUTEX_NATIVE
        • RTI_MQTT_MUTEX_INITIALIZER_NATIVE
        • RTI_MQTT_Mutex_INITIALIZER
        • RTI_MQTT_Mutex_assert
        • RTI_MQTT_Mutex_release
        • RTI_MQTT_Mutex_assert_w_state
        • RTI_MQTT_Mutex_release_w_state
        • RTI_MQTT_Mutex_release_from_state
        • RTI_MQTT_ThreadFn
        • RTI_MQTT_Mutex
        • RTI_MQTT_Thread_spawn()
        • RTI_MQTT_Thread_join()
        • RTI_MQTT_Mutex_initialize()
        • RTI_MQTT_Mutex_finalize()
        • RTI_MQTT_Mutex_take()
        • RTI_MQTT_Mutex_give()
      • 3.2.7. IDL Types
        • 3.2.7.1. MQTT Configuration
        • 3.2.7.2. MQTT Message
        • 3.2.7.3. MQTT Client
        • 3.2.7.4. MQTT Subscription
        • 3.2.7.5. MQTT Publication
    • 3.3. RTI Routing Service Adapter Plugin
      • RTI_RS_MQTT_ADAPTER_VERSION_MAJOR
      • RTI_RS_MQTT_ADAPTER_VERSION_MINOR
      • RTI_RS_MQTT_ADAPTER_VERSION_RELEASE
      • RTI_RS_MQTT_ADAPTER_VERSION_REVISION
      • RTI_RS_MQTT_AdapterPlugin_create()
      • RTI_RS_MQTT_AdapterPlugin_VERSION
    • 3.4. Configuration Properties
      • 3.4.1. MQTT Client Configuration
        • RTI_MQTT_PROPERTY_PREFIX_CLIENT
        • RTI_MQTT_PROPERTY_PREFIX_CLIENT_SSL
        • RTI_MQTT_PROPERTY_CLIENT_ID
        • RTI_MQTT_PROPERTY_CLIENT_PROTOCOL_VERSION
        • RTI_MQTT_PROPERTY_CLIENT_SERVERS
        • RTI_MQTT_PROPERTY_CLIENT_CONNECTION_TIMEOUT
        • RTI_MQTT_PROPERTY_CLIENT_CONNECTION_TIMEOUT_SECONDS
        • RTI_MQTT_PROPERTY_CLIENT_CONNECTION_TIMEOUT_NANOSECONDS
        • RTI_MQTT_PROPERTY_CLIENT_MAX_CONNECTION_RETRIES
        • RTI_MQTT_PROPERTY_CLIENT_KEEP_ALIVE_PERIOD
        • RTI_MQTT_PROPERTY_CLIENT_KEEP_ALIVE_PERIOD_SECONDS
        • RTI_MQTT_PROPERTY_CLIENT_KEEP_ALIVE_PERIOD_NANOSECONDS
        • RTI_MQTT_PROPERTY_CLIENT_CLEAN_SESSION
        • RTI_MQTT_PROPERTY_CLIENT_UNSUBSCRIBE_ON_DISCONNECT
        • RTI_MQTT_PROPERTY_CLIENT_MAX_REPLY_TIMEOUT
        • RTI_MQTT_PROPERTY_CLIENT_MAX_REPLY_TIMEOUT_SECONDS
        • RTI_MQTT_PROPERTY_CLIENT_MAX_REPLY_TIMEOUT_NANOSECONDS
        • RTI_MQTT_PROPERTY_CLIENT_RECONNECT
        • RTI_MQTT_PROPERTY_CLIENT_MAX_UNACK_MESSAGES
        • RTI_MQTT_PROPERTY_CLIENT_PERSISTENCE
        • RTI_MQTT_PROPERTY_CLIENT_PERSISTENCE_STORAGE
        • RTI_MQTT_PROPERTY_CLIENT_USERNAME
        • RTI_MQTT_PROPERTY_CLIENT_PASSWORD
      • 3.4.2. MQTT Subscription Configuration
        • RTI_MQTT_PROPERTY_PREFIX_SUBSCRIPTION
        • RTI_MQTT_PROPERTY_SUBSCRIPTION_TOPICS
        • RTI_MQTT_PROPERTY_SUBSCRIPTION_MAX_QOS
        • RTI_MQTT_PROPERTY_SUBSCRIPTION_QUEUE_SIZE
      • 3.4.3. MQTT Publication Configuration
        • RTI_MQTT_PROPERTY_PREFIX_PUBLICATION
        • RTI_MQTT_PROPERTY_PUBLICATION_TOPIC
        • RTI_MQTT_PROPERTY_PUBLICATION_QOS
        • RTI_MQTT_PROPERTY_PUBLICATION_RETAINED
        • RTI_MQTT_PROPERTY_PUBLICATION_USE_MESSAGE_INFO
        • RTI_MQTT_PROPERTY_PUBLICATION_MAX_WAIT_TIME
        • RTI_MQTT_PROPERTY_PUBLICATION_MAX_WAIT_TIME_SECONDS
        • RTI_MQTT_PROPERTY_PUBLICATION_MAX_WAIT_TIME_NANOSECONDS
  • 4. Additional Resources
    • 4.1. Examples
    • 4.2. Tests
  • 5. Release Notes
    • 5.1. Supported Platforms
  • 6. Copyrights
RTI Routing Service MQTT Adapter
  • Search

© Copyright 2019, Real-Time Innovations, Inc.

Built with Sphinx using a theme provided by Read the Docs.