Package | Description |
---|---|
org.eclipse.kapua.gateway.client |
Gateway client SDK for Eclipse Kapuaâ„¢
|
org.eclipse.kapua.gateway.client.mqtt |
Abstract base classes for implementing MQTT based clients
|
org.eclipse.kapua.gateway.client.spi |
Abstract base classes for implementing
Client s |
Modifier and Type | Method and Description |
---|---|
default void |
Data.subscribe(MessageHandler handler)
Receive messages on this data topic
|
void |
Data.subscribe(MessageHandler handler,
ErrorHandler<? extends Throwable> errorHandler)
Receive messages and handle reception errors on this data topic
|
Modifier and Type | Method and Description |
---|---|
protected void |
MqttApplication.handleMessage(MessageHandler handler,
ByteBuffer buffer) |
protected CompletionStage<?> |
MqttApplication.internalSubscribe(Topic topic,
MessageHandler handler,
ErrorHandler<? extends Throwable> errorHandler) |
Modifier and Type | Method and Description |
---|---|
protected abstract CompletionStage<?> |
AbstractApplication.internalSubscribe(Topic topic,
MessageHandler handler,
ErrorHandler<? extends Throwable> errorHandler) |
void |
AbstractData.subscribe(MessageHandler handler,
ErrorHandler<? extends Throwable> errorHandler) |
CompletionStage<?> |
AbstractApplication.subscribe(Topic topic,
MessageHandler handler,
ErrorHandler<? extends Throwable> errorHandler) |
Copyright © 2017. All rights reserved.