public class MqttAsyncCallback extends OneTimeTriggerAbstractCallback implements org.eclipse.paho.client.mqttv3.MqttCallback
tenantDomain
Constructor and Description |
---|
MqttAsyncCallback(org.eclipse.paho.client.mqttv3.MqttAsyncClient mqttAsyncClient,
MqttInjectHandler injectHandler,
MqttConnectionFactory confac,
org.eclipse.paho.client.mqttv3.MqttConnectOptions connectOptions,
Properties mqttProperties) |
Modifier and Type | Method and Description |
---|---|
void |
connectionLost(Throwable throwable)
Handle losing connection with the server.
|
void |
deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken iMqttDeliveryToken) |
MqttConnectionConsumer |
getMqttConnectionConsumer() |
org.eclipse.paho.client.mqttv3.MqttConnectOptions |
getMqttConnectionOptions() |
String |
getName()
get the inbound endpoint name
|
void |
messageArrived(String topic,
org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) |
protected void |
reConnect() |
void |
setMqttConnectionConsumer(MqttConnectionConsumer connectionConsumer) |
void |
setName(String name)
Set the inbound endpoint name
|
void |
shutdown() |
void |
updateInjectHandler(MqttInjectHandler injectHandler) |
handleReconnection, isCallbackSuspended, isInboundRunnerMode, releaseCallbackSuspension, setInboundRunnerMode, setTenantDomain, startInboundTenantLoading
public MqttAsyncCallback(org.eclipse.paho.client.mqttv3.MqttAsyncClient mqttAsyncClient, MqttInjectHandler injectHandler, MqttConnectionFactory confac, org.eclipse.paho.client.mqttv3.MqttConnectOptions connectOptions, Properties mqttProperties)
public void connectionLost(Throwable throwable)
connectionLost
in interface org.eclipse.paho.client.mqttv3.MqttCallback
throwable
- Throwable connection lostprotected void reConnect()
reConnect
in class OneTimeTriggerAbstractCallback
public void messageArrived(String topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) throws org.eclipse.paho.client.mqttv3.MqttException
messageArrived
in interface org.eclipse.paho.client.mqttv3.MqttCallback
org.eclipse.paho.client.mqttv3.MqttException
public void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken iMqttDeliveryToken)
deliveryComplete
in interface org.eclipse.paho.client.mqttv3.MqttCallback
public void setMqttConnectionConsumer(MqttConnectionConsumer connectionConsumer)
public MqttConnectionConsumer getMqttConnectionConsumer()
public org.eclipse.paho.client.mqttv3.MqttConnectOptions getMqttConnectionOptions()
public void updateInjectHandler(MqttInjectHandler injectHandler)
public void shutdown()
shutdown
in class OneTimeTriggerAbstractCallback
public void setName(String name)
name
- public String getName()
Copyright © 2018 WSO2. All rights reserved.