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 |
---|---|
static ErrorHandler<RuntimeException> |
Errors.handle(BiConsumer<Throwable,Optional<Payload>> handler) |
static ErrorHandler<RuntimeException> |
Errors.ignore() |
Modifier and Type | Method and Description |
---|---|
default <Y extends Throwable> |
Sender.errors(ErrorHandler<Y> errorHandler) |
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 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.