Ahora necesita crear un nuevo cliente MQTT y conectarse a su agente de mensajería MQTT. Como se muestra en este tutorial, puede alojar un corredor público en HiveMQ o cualquier otro corredor de su elección. En un proyecto más serio, use un corredor diferente.
Manejarás todo esto en el constructor. Primero agregue esta definición de método a la PUBLIC SECTION de tu clase:
METHODS constructor.
Agregue la definición de datos de este objeto local al PRIVATE SECTION de su clase, lo necesitará en un minuto.
DATA: mo_mqtt_client TYPE REF TO if_mqtt_client.
El creador de URL lleva el agente de HiveMQ MQTT y el caso del controlador de eventos al modo de fábrica CREATE_BY_URL, que restaura un nuevo objeto Cliente MQTT MO_MQTT_CLIENT. Finalmente, se establece un vínculo con el agente de mensajería especificado.
Pegue el siguiente método en su aplicación de clase.
METHOD constructor.
TRY.
" create MQTT client
cl_mqtt_client_manager=>create_by_url(
EXPORTING
i_url = 'ws://broker.hivemq.com:8000/mqtt'
i_event_handler = me
RECEIVING
r_client = mo_mqtt_client ).
" establish the connection
mo_mqtt_client->connect( ).
CATCH cx_mqtt_error.
" to do: error handling, e.g. write error log!
ENDTRY.
ENDMETHOD.