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 |
---|---|
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.