public class MqttApplication extends AbstractApplication
Application.BuilderapplicationId, subscriptions, transport| Constructor and Description |
|---|
MqttApplication(MqttClient client,
String applicationId,
Executor executor) |
| Modifier and Type | Method and Description |
|---|---|
AbstractData |
data(Topic topic)
Lookup a data controller to an application topic
|
protected void |
handleMessage(MessageHandler handler,
ByteBuffer buffer) |
protected CompletionStage<?> |
internalSubscribe(Topic topic,
MessageHandler handler,
ErrorHandler<? extends Throwable> errorHandler) |
protected void |
publish(Topic topic,
Payload payload) |
checkClosed, close, handleConnected, handleDisconnected, subscribe, transportpublic MqttApplication(MqttClient client, String applicationId, Executor executor)
public AbstractData data(Topic topic)
Applicationdata in interface Applicationdata in class AbstractApplicationtopic - the topic the controller is bound to, must never be nullprotected void publish(Topic topic, Payload payload) throws Exception
publish in class AbstractApplicationExceptionprotected CompletionStage<?> internalSubscribe(Topic topic, MessageHandler handler, ErrorHandler<? extends Throwable> errorHandler) throws Exception
internalSubscribe in class AbstractApplicationExceptionprotected void handleMessage(MessageHandler handler, ByteBuffer buffer) throws Exception
ExceptionCopyright © 2017. All rights reserved.