org.eclipse.kapua.gateway.client.mqtt

Class MqttClient

java.lang.Object

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

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

All Implemented Interfaces:

AutoCloseable, Client

Direct Known Subclasses:

FuseClient, PahoClient

public abstract class MqttClient
extends AbstractClient

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MqttClient.Builder<T extends MqttClient.Builder<T>>

Field Summary

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

executor

Constructor Summary

Constructors

Constructor and Description
MqttClient(ScheduledExecutorService executor, BinaryPayloadCodec codec, MqttNamespace namespace, String clientId, Set<Module> modules)

Method Summary

Modifier and Type	Method and Description
protected BinaryPayloadCodec	getCodec()
String	getMqttClientId()
protected AbstractApplication	internalCreateApplication(Application.Builder builder, String applicationId)
protected void	internalUnsubscribe(String applicationId, Collection<Topic> topics)
protected void	publish(String applicationId, Topic topic, ByteBuffer buffer)
abstract void	publishMqtt(String topic, ByteBuffer payload)
protected CompletionStage<?>	subscribe(String applicationId, Topic topic, MqttMessageHandler messageHandler)
protected abstract CompletionStage<?>	subscribeMqtt(String topic, MqttMessageHandler messageHandler)
protected abstract void	unsubscribeMqtt(Set<String> mqttTopics)

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

buildApplication, handleApplicationClosed, handleConnected, handleDisconnected, 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

Methods inherited from interface java.lang.AutoCloseable

close

Constructor Detail

MqttClient

public MqttClient(ScheduledExecutorService executor,
                  BinaryPayloadCodec codec,
                  MqttNamespace namespace,
                  String clientId,
                  Set<Module> modules)

Method Detail

publish

protected void publish(String applicationId,
                       Topic topic,
                       ByteBuffer buffer)
                throws Exception

Throws:

Exception

publishMqtt

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

Throws:

Exception

subscribeMqtt

protected abstract CompletionStage<?> subscribeMqtt(String topic,
                                                    MqttMessageHandler messageHandler)
                                             throws Exception

Throws:

Exception

subscribe

protected CompletionStage<?> subscribe(String applicationId,
                                       Topic topic,
                                       MqttMessageHandler messageHandler)
                                throws Exception

Throws:

Exception

internalUnsubscribe

protected void internalUnsubscribe(String applicationId,
                                   Collection<Topic> topics)
                            throws Exception

Specified by:

internalUnsubscribe in class AbstractClient

Throws:

Exception

unsubscribeMqtt

protected abstract void unsubscribeMqtt(Set<String> mqttTopics)
                                 throws Exception

Throws:

Exception

getMqttClientId

public String getMqttClientId()

internalCreateApplication

protected AbstractApplication internalCreateApplication(Application.Builder builder,
                                                        String applicationId)

Specified by:

internalCreateApplication in class AbstractClient

getCodec

protected BinaryPayloadCodec getCodec()