org.eclipse.kapua.gateway.client.mqtt.fuse

Class FuseClient

java.lang.Object

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

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

org.eclipse.kapua.gateway.client.mqtt.fuse.FuseClient

All Implemented Interfaces:

AutoCloseable, Client

public class FuseClient
extends MqttClient

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FuseClient.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	handleMessageArrived(String topic, org.fusesource.hawtbuf.Buffer payload, org.fusesource.mqtt.client.Callback<org.fusesource.mqtt.client.Callback<Void>> ack)
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, 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

Method Detail

close

public void close()

publishMqtt

public void publishMqtt(String topic,
                        ByteBuffer payload)

Specified by:

publishMqtt in class MqttClient

subscribeMqtt

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

Specified by:

subscribeMqtt in class MqttClient

unsubscribeMqtt

protected void unsubscribeMqtt(Set<String> mqttTopics)

Specified by:

unsubscribeMqtt in class MqttClient

handleMessageArrived

protected void handleMessageArrived(String topic,
                                    org.fusesource.hawtbuf.Buffer payload,
                                    org.fusesource.mqtt.client.Callback<org.fusesource.mqtt.client.Callback<Void>> ack)