Package br.com.MosquittoDynamicSecurity.dynsec.publisher

Class DynSecPublisher

java.lang.Object

br.com.MosquittoDynamicSecurity.dynsec.publisher.DynSecPublisher

All Implemented Interfaces:

org.eclipse.paho.client.mqttv3.MqttCallback

public class DynSecPublisher
extends Object
implements org.eclipse.paho.client.mqttv3.MqttCallback

A classe DynSecPublisher é responsável por receber os comandos de client, role e group e publicar no tópico de controle de segurança dinâmica do Mosquitto. Ela implementa a interface MqttCallback para receber a resposta dos comandos enviados e imprimir no console.

Since:

Set 2022

Version:

1.0

Author:

Douglas Ferreira da Silva

Constructor Summary

Constructors

Constructor	Description
DynSecPublisher(String uri, String username, String password, String clientId)

Method Summary

Modifier and Type	Method	Description
DynSecPublisher	addCommand(com.google.gson.JsonObject command)	Método para adicionar comandos a serem executados pelo método publish()
void	connectionLost(Throwable cause)	Método da interface MqttCallback que é executado ao perder a conexão com o Broker Mosquitto
void	deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)
String	getClientId()
String	getPassword()
String	getTopicToPublish()
String	getTopicToSubscribe()
String	getUri()
String	getUsername()
void	messageArrived(String topic, org.eclipse.paho.client.mqttv3.MqttMessage message)	Método da interface MqttCallback que é executado ao receber uma mensagem no tópico no qual foi feito o subscribe
void	publish()	Método utilizado para executar/publicar os comandos adicionados ao atributo commands.
DynSecPublisher	removeCommands()	Método para limpar a lista de comandos a serem executados pelo método publish()
String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

DynSecPublisher

public DynSecPublisher(String uri,
 String username,
 String password,
 String clientId)

Method Details

addCommand

public DynSecPublisher addCommand(com.google.gson.JsonObject command)

Método para adicionar comandos a serem executados pelo método publish()

Parameters:

command - Objeto do tipo JsonObject contendo os comandos a serem publicados

Returns:

Retorna a própria classe permitindo o encadeamento de métodos

removeCommands

public DynSecPublisher removeCommands()

Método para limpar a lista de comandos a serem executados pelo método publish()

Returns:

Retorna a própria classe permitindo o encadeamento de métodos

publish

public void publish()

Método utilizado para executar/publicar os comandos adicionados ao atributo commands.

connectionLost

public void connectionLost(Throwable cause)

Método da interface MqttCallback que é executado ao perder a conexão com o Broker Mosquitto

Specified by:

connectionLost in interface org.eclipse.paho.client.mqttv3.MqttCallback

messageArrived

public void messageArrived(String topic,
 org.eclipse.paho.client.mqttv3.MqttMessage message)
                    throws Exception

Método da interface MqttCallback que é executado ao receber uma mensagem no tópico no qual foi feito o subscribe

Specified by:

messageArrived in interface org.eclipse.paho.client.mqttv3.MqttCallback

Throws:

Exception

deliveryComplete

public void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)

Specified by:

deliveryComplete in interface org.eclipse.paho.client.mqttv3.MqttCallback

getUri

public String getUri()

getUsername

public String getUsername()

getPassword

public String getPassword()

getClientId

public String getClientId()

getTopicToPublish

public String getTopicToPublish()

getTopicToSubscribe

public String getTopicToSubscribe()

toString

public String toString()

Overrides:

toString in class Object