| 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
Clients |
| Modifier and Type | Method and Description |
|---|---|
static Topic |
Topic.of(List<String> segments) |
static Topic |
Topic.of(String first,
String... strings) |
static Topic |
Topic.split(String path) |
| Modifier and Type | Method and Description |
|---|---|
Data |
Application.data(Topic topic)
Lookup a data controller to an application topic
|
| Modifier and Type | Method and Description |
|---|---|
String |
KuraNamespace.dataTopic(String clientId,
String applicationId,
Topic topic) |
| Modifier and Type | Method and Description |
|---|---|
AbstractData |
MqttApplication.data(Topic topic) |
String |
MqttNamespace.dataTopic(String clientId,
String applicationId,
Topic topic)
Render an MQTT topic for the provided data topic
|
protected CompletionStage<?> |
MqttApplication.internalSubscribe(Topic topic,
MessageHandler handler,
ErrorHandler<? extends Throwable> errorHandler) |
protected void |
MqttClient.publish(String applicationId,
Topic topic,
ByteBuffer buffer) |
protected void |
MqttApplication.publish(Topic topic,
Payload payload) |
protected CompletionStage<?> |
MqttClient.subscribe(String applicationId,
Topic topic,
MqttMessageHandler messageHandler) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
MqttClient.internalUnsubscribe(String applicationId,
Collection<Topic> topics) |
| Modifier and Type | Field and Description |
|---|---|
protected Set<Topic> |
AbstractApplication.subscriptions |
| Modifier and Type | Method and Description |
|---|---|
abstract AbstractData |
AbstractApplication.data(Topic topic) |
protected abstract CompletionStage<?> |
AbstractApplication.internalSubscribe(Topic topic,
MessageHandler handler,
ErrorHandler<? extends Throwable> errorHandler) |
protected abstract void |
AbstractApplication.publish(Topic topic,
Payload payload) |
CompletionStage<?> |
AbstractApplication.subscribe(Topic topic,
MessageHandler handler,
ErrorHandler<? extends Throwable> errorHandler) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
AbstractClient.internalCloseApplication(String applicationId,
Set<Topic> topics,
AbstractApplication application) |
protected abstract void |
AbstractClient.internalUnsubscribe(String applicationId,
Collection<Topic> topics) |
| Constructor and Description |
|---|
AbstractData(AbstractApplication application,
Topic topic) |
Copyright © 2017. All rights reserved.