Package io.vertigo.connectors.mqtt

Class MosquittoConnector

java.lang.Object

io.vertigo.connectors.mqtt.MosquittoConnector

All Implemented Interfaces:

io.vertigo.core.node.component.Activeable, io.vertigo.core.node.component.Connector<org.eclipse.paho.client.mqttv3.MqttClient>, io.vertigo.core.node.component.CoreComponent

public class MosquittoConnector
extends Object
implements io.vertigo.core.node.component.Connector<org.eclipse.paho.client.mqttv3.MqttClient>, io.vertigo.core.node.component.Activeable

Author:

mlaroche

Field Summary

Fields inherited from interface io.vertigo.core.node.component.Connector

DEFAULT_CONNECTOR_NAME

Constructor Summary

Constructors

Constructor	Description
MosquittoConnector(Optional<String> connectionNameOpt, String brokerHost, Optional<String> clientIdOpt)

Method Summary

Modifier and Type	Method	Description
org.eclipse.paho.client.mqttv3.MqttClient	getClient()
String	getName()
void	start()
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MosquittoConnector

@Inject
public MosquittoConnector(Optional<String> connectionNameOpt,
 String brokerHost,
 Optional<String> clientIdOpt)

Method Details

start

public void start()

Specified by:

start in interface io.vertigo.core.node.component.Activeable

stop

public void stop()

Specified by:

stop in interface io.vertigo.core.node.component.Activeable

getClient

public org.eclipse.paho.client.mqttv3.MqttClient getClient()

Specified by:

getClient in interface io.vertigo.core.node.component.Connector<org.eclipse.paho.client.mqttv3.MqttClient>

getName

public String getName()

Specified by:

getName in interface io.vertigo.core.node.component.Connector<org.eclipse.paho.client.mqttv3.MqttClient>