org.eclipse.kapua.gateway.client.mqtt.paho

Class PahoClient

java.lang.Object

org.eclipse.kapua.gateway.client.spi.AbstractClient

org.eclipse.kapua.gateway.client.mqtt.MqttClient

org.eclipse.kapua.gateway.client.mqtt.paho.PahoClient

All Implemented Interfaces:

AutoCloseable, Client

public class PahoClient
extends MqttClient

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PahoClient.Builder

Field Summary

Fields inherited from class org.eclipse.kapua.gateway.client.spi.AbstractClient

executor

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	connect()
protected void	handleConnected()
protected void	handleDisconnected()
protected void	handleMessageArrived(String topic, org.eclipse.paho.client.mqttv3.MqttMessage message)
protected void	publish(String topic, ByteBuffer payload)
void	publishMqtt(String topic, ByteBuffer payload)
protected CompletionStage<?>	subscribeMqtt(String topic, MqttMessageHandler messageHandler)
protected void	unsubscribeMqtt(Set<String> mqttTopics)

Methods inherited from class org.eclipse.kapua.gateway.client.mqtt.MqttClient

getCodec, getMqttClientId, internalCreateApplication, internalUnsubscribe, publish, subscribe

Methods inherited from class org.eclipse.kapua.gateway.client.spi.AbstractClient

buildApplication, handleApplicationClosed, internalBuildApplication, internalCloseApplication, notifyAddApplication, notifyConnected, notifyDisconnected, notifyRemoveApplication, transport

Methods inherited from class java.lang.Object

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

Method Detail

connect

protected void connect()

close

public void close()

handleConnected

protected void handleConnected()

Overrides:

handleConnected in class AbstractClient

handleDisconnected

protected void handleDisconnected()

Overrides:

handleDisconnected in class AbstractClient

publishMqtt

public void publishMqtt(String topic,
                        ByteBuffer payload)
                 throws Exception

Specified by:

publishMqtt in class MqttClient

Throws:

Exception

publish

protected void publish(String topic,
                       ByteBuffer payload)
                throws org.eclipse.paho.client.mqttv3.MqttException

Throws:

org.eclipse.paho.client.mqttv3.MqttException

subscribeMqtt

protected CompletionStage<?> subscribeMqtt(String topic,
                                           MqttMessageHandler messageHandler)
                                    throws org.eclipse.paho.client.mqttv3.MqttException

Specified by:

subscribeMqtt in class MqttClient

Throws:

org.eclipse.paho.client.mqttv3.MqttException

unsubscribeMqtt

protected void unsubscribeMqtt(Set<String> mqttTopics)
                        throws org.eclipse.paho.client.mqttv3.MqttException

Specified by:

unsubscribeMqtt in class MqttClient

Throws:

org.eclipse.paho.client.mqttv3.MqttException

handleMessageArrived

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

Throws:

Exception