Package | Description |
---|---|
org.eclipse.kapua.gateway.client |
Gateway client SDK for Eclipse Kapuaâ„¢
|
org.eclipse.kapua.gateway.client.kura | |
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 |
---|---|
Payload |
Payload.Builder.build() |
Payload |
BinaryPayloadCodec.decode(ByteBuffer buffer)
Decode a
Payload structure from the provided BLOB |
static Payload |
Payload.of(Instant timestamp,
Map<String,Object> values) |
static Payload |
Payload.of(Instant timestamp,
String key,
Object value) |
static Payload |
Payload.of(Map<String,Object> values) |
static Payload |
Payload.of(String key,
Object value) |
Modifier and Type | Method and Description |
---|---|
ByteBuffer |
BinaryPayloadCodec.encode(Payload payload,
ByteBuffer buffer)
Encode a
Payload structure into a BLOB |
void |
MessageHandler.handleMessage(Payload payload) |
void |
Sender.send(Payload payload) |
Modifier and Type | Method and Description |
---|---|
static ErrorHandler<RuntimeException> |
Errors.handle(BiConsumer<Throwable,Optional<Payload>> handler) |
void |
ErrorHandler.handleError(Throwable e,
Optional<Payload> payload) |
static void |
Errors.ignore(Throwable e,
Optional<Payload> payload) |
Modifier and Type | Method and Description |
---|---|
Payload |
KuraBinaryPayloadCodec.decode(ByteBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
ByteBuffer |
KuraBinaryPayloadCodec.encode(Payload payload,
ByteBuffer buffer) |
Modifier and Type | Method and Description |
---|---|
protected void |
MqttApplication.publish(Topic topic,
Payload payload) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractApplication.publish(Topic topic,
Payload payload) |
void |
AbstractData.send(Payload payload) |
Copyright © 2017. All rights reserved.