public class MqttTransporter extends Transporter implements org.eclipse.paho.client.mqttv3.MqttCallback
ServiceBroker broker = ServiceBroker.builder().nodeID("node1").transporter(new MqttTransporter("localhost"))
.build();
Required dependency:| Modifier and Type | Field and Description |
|---|---|
protected boolean |
cleanSession |
protected org.eclipse.paho.client.mqttv3.MqttAsyncClient |
client |
protected int |
connectionTimeout |
protected java.util.Properties |
customWebSocketHeaders |
protected int |
executorServiceTimeout |
protected javax.net.ssl.HostnameVerifier |
hostnameVerifier |
protected boolean |
httpsHostnameVerificationEnabled |
protected int |
keepAliveInterval |
protected int |
maxInflight |
protected int |
mqttVersion |
protected java.lang.String |
password |
protected org.eclipse.paho.client.mqttv3.persist.MemoryPersistence |
persistence |
protected int |
qos |
protected javax.net.SocketFactory |
socketFactory |
protected java.util.Properties |
sslClientProps |
protected java.lang.String[] |
urls |
protected java.lang.String |
username |
checkTimeoutTimer, counterTransporterPacketsReceivedBytes, counterTransporterPacketsReceivedTotal, counterTransporterPacketsSentBytes, counterTransporterPacketsSentTotal, debug, debugHeartbeats, disconnectChannel, discoverBroadcastChannel, discoverChannel, eventbus, eventChannel, executor, gaugeTransitConnected, heartbeatChannel, heartbeatInterval, heartbeatTimeout, heartBeatTimer, infoBroadcastChannel, infoChannel, infoScheduled, infoScheduledAt, instanceID, lastReceivedMessageAt, metrics, monitor, namespace, nodeID, nodes, offlineTimeout, PACKET_DISCONNECT, PACKET_DISCOVER, PACKET_EVENT, PACKET_HEARTBEAT, PACKET_INFO, PACKET_PING, PACKET_PONG, PACKET_REQUEST, PACKET_RESPONSE, pingChannel, pongChannel, preferHostname, prefix, protocolVersion, registry, requestChannel, responseChannel, scheduler, serializer, serviceInvoker, subscriptionTimeout, uidGenerator, usingJsonSerializerbroker, logger, nameMOLECULER_CACHER_CLEAN_TIME, MOLECULER_CACHER_CLEAN_TIME_DESC, MOLECULER_CACHER_CLEAN_TOTAL, MOLECULER_CACHER_CLEAN_TOTAL_DESC, MOLECULER_CACHER_DEL_TIME, MOLECULER_CACHER_DEL_TIME_DESC, MOLECULER_CACHER_DEL_TOTAL, MOLECULER_CACHER_DEL_TOTAL_DESC, MOLECULER_CACHER_EXPIRED_TOTAL, MOLECULER_CACHER_EXPIRED_TOTAL_DESC, MOLECULER_CACHER_FOUND_TOTAL, MOLECULER_CACHER_FOUND_TOTAL_DESC, MOLECULER_CACHER_GET_TIME, MOLECULER_CACHER_GET_TIME_DESC, MOLECULER_CACHER_GET_TOTAL, MOLECULER_CACHER_GET_TOTAL_DESC, MOLECULER_CACHER_SET_TIME, MOLECULER_CACHER_SET_TIME_DESC, MOLECULER_CACHER_SET_TOTAL, MOLECULER_CACHER_SET_TOTAL_DESC, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL_DESC, MOLECULER_EVENT_BROADCAST_TOTAL, MOLECULER_EVENT_BROADCAST_TOTAL_DESC, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL_DESC, MOLECULER_EVENT_EMIT_TOTAL, MOLECULER_EVENT_EMIT_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_ACTIVE, MOLECULER_EVENT_RECEIVED_ACTIVE_DESC, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_TIME, MOLECULER_EVENT_RECEIVED_TIME_DESC, MOLECULER_EVENT_RECEIVED_TOTAL, MOLECULER_EVENT_RECEIVED_TOTAL_DESC, MOLECULER_EXECUTOR, MOLECULER_REQUEST_ACTIVE, MOLECULER_REQUEST_ACTIVE_DESC, MOLECULER_REQUEST_ERROR_TOTAL, MOLECULER_REQUEST_ERROR_TOTAL_DESC, MOLECULER_REQUEST_LEVELS, MOLECULER_REQUEST_LEVELS_DESC, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL_DESC, MOLECULER_REQUEST_TIME, MOLECULER_REQUEST_TIME_DESC, MOLECULER_REQUEST_TIMEOUT_TOTAL, MOLECULER_REQUEST_TIMEOUT_TOTAL_DESC, MOLECULER_REQUEST_TOTAL, MOLECULER_REQUEST_TOTAL_DESC, MOLECULER_SCHEDULER, MOLECULER_TRANSIT_CONNECTED, MOLECULER_TRANSIT_CONNECTED_DESC, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL_DESC, MOLECULER_TRANSIT_REQUESTS_ACTIVE, MOLECULER_TRANSIT_REQUESTS_ACTIVE_DESC, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL_DESC| Constructor and Description |
|---|
MqttTransporter() |
MqttTransporter(java.lang.String... urls) |
MqttTransporter(java.lang.String username,
java.lang.String password,
java.lang.String... urls) |
| Modifier and Type | Method and Description |
|---|---|
void |
connect() |
void |
connectionLost(java.lang.Throwable cause) |
void |
deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token) |
protected void |
disconnect() |
protected void |
error(java.lang.Throwable cause)
Any I/O error occurred.
|
int |
getConnectionTimeout() |
java.util.Properties |
getCustomWebSocketHeaders() |
int |
getExecutorServiceTimeout() |
javax.net.ssl.HostnameVerifier |
getHostnameVerifier() |
int |
getKeepAliveInterval() |
int |
getMaxInflight() |
int |
getMqttVersion() |
java.lang.String |
getPassword() |
org.eclipse.paho.client.mqttv3.persist.MemoryPersistence |
getPersistence() |
int |
getQos() |
javax.net.SocketFactory |
getSocketFactory() |
java.util.Properties |
getSslClientProps() |
java.lang.String[] |
getUrls() |
java.lang.String |
getUsername() |
boolean |
isCleanSession() |
boolean |
isHttpsHostnameVerificationEnabled() |
void |
messageArrived(java.lang.String topic,
org.eclipse.paho.client.mqttv3.MqttMessage message) |
void |
publish(java.lang.String channel,
io.datatree.Tree message) |
protected void |
reconnect(java.lang.Throwable cause) |
void |
setCleanSession(boolean cleanSession) |
void |
setConnectionTimeout(int connectionTimeout) |
void |
setCustomWebSocketHeaders(java.util.Properties customWebSocketHeaders) |
void |
setExecutorServiceTimeout(int executorServiceTimeout) |
void |
setHostnameVerifier(javax.net.ssl.HostnameVerifier hostnameVerifier) |
void |
setHttpsHostnameVerificationEnabled(boolean httpsHostnameVerificationEnabled) |
void |
setKeepAliveInterval(int keepAliveInterval) |
void |
setMaxInflight(int maxInflight) |
void |
setMqttVersion(int mqttVersion) |
void |
setPassword(java.lang.String password) |
void |
setPersistence(org.eclipse.paho.client.mqttv3.persist.MemoryPersistence persistence) |
void |
setQos(int qos) |
void |
setSocketFactory(javax.net.SocketFactory socketFactory) |
void |
setSslClientProps(java.util.Properties sslClientProps) |
void |
setUrls(java.lang.String... urls) |
void |
setUsername(java.lang.String username) |
void |
stopped()
Closes transporter.
|
io.datatree.Promise |
subscribe(java.lang.String channel) |
broadcastInfoPacket, broadcastNodeConnected, broadcastNodeDisconnected, broadcastNodeUpdated, broadcastTransporterConnected, broadcastTransporterDisconnected, channel, checkTimeouts, connected, connected, createPingPacket, getAddress, getAllNodeIDs, getCpuUsage, getDescriptor, getHeartbeatInterval, getHeartbeatTimeout, getInstanceID, getLastHeartbeatTime, getNamespace, getOfflineTimeout, getPrefix, getSerializer, getSubscriptionTimeout, isDebug, isDebugHeartbeats, isOnline, isPreferHostname, processReceivedMessage, processReceivedMessage, publish, received, scheduleInfoPacket, sendClosePacket, sendDataPacket, sendDisconnectPacket, sendDiscoverPacket, sendErrorPacket, sendEventPacket, sendHeartbeatPacket, sendInfoPacket, sendPongPacket, sendRequestPacket, setDebug, setDebugHeartbeats, setHeartbeatInterval, setHeartbeatTimeout, setNamespace, setOfflineTimeout, setPreferHostname, setPrefix, setSerializer, setSubscriptionTimeout, started, subscribe, updateNodeInfogetBroker, getLogger, getNameprotected java.lang.String username
protected java.lang.String password
protected java.lang.String[] urls
protected int qos
protected boolean cleanSession
protected org.eclipse.paho.client.mqttv3.persist.MemoryPersistence persistence
protected int connectionTimeout
protected int executorServiceTimeout
protected boolean httpsHostnameVerificationEnabled
protected int keepAliveInterval
protected int maxInflight
protected int mqttVersion
protected javax.net.SocketFactory socketFactory
protected javax.net.ssl.HostnameVerifier hostnameVerifier
protected java.util.Properties sslClientProps
protected java.util.Properties customWebSocketHeaders
protected org.eclipse.paho.client.mqttv3.MqttAsyncClient client
public MqttTransporter()
public MqttTransporter(java.lang.String... urls)
public MqttTransporter(java.lang.String username,
java.lang.String password,
java.lang.String... urls)
public void connect()
connect in class Transporterprotected void disconnect()
protected void reconnect(java.lang.Throwable cause)
public void connectionLost(java.lang.Throwable cause)
connectionLost in interface org.eclipse.paho.client.mqttv3.MqttCallbackprotected void error(java.lang.Throwable cause)
Transportererror in class Transportercause - I/O errorpublic void stopped()
stopped in interface MoleculerLifecyclestopped in class Transporterpublic io.datatree.Promise subscribe(java.lang.String channel)
subscribe in class Transporterpublic void publish(java.lang.String channel,
io.datatree.Tree message)
publish in class Transporterpublic void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)
deliveryComplete in interface org.eclipse.paho.client.mqttv3.MqttCallbackpublic void messageArrived(java.lang.String topic,
org.eclipse.paho.client.mqttv3.MqttMessage message)
throws java.lang.Exception
messageArrived in interface org.eclipse.paho.client.mqttv3.MqttCallbackjava.lang.Exceptionpublic java.lang.String[] getUrls()
public void setUrls(java.lang.String... urls)
public java.lang.String getUsername()
public void setUsername(java.lang.String username)
public java.lang.String getPassword()
public void setPassword(java.lang.String password)
public int getQos()
public void setQos(int qos)
public boolean isCleanSession()
public void setCleanSession(boolean cleanSession)
public org.eclipse.paho.client.mqttv3.persist.MemoryPersistence getPersistence()
public void setPersistence(org.eclipse.paho.client.mqttv3.persist.MemoryPersistence persistence)
public int getConnectionTimeout()
public void setConnectionTimeout(int connectionTimeout)
public int getExecutorServiceTimeout()
public void setExecutorServiceTimeout(int executorServiceTimeout)
public boolean isHttpsHostnameVerificationEnabled()
public void setHttpsHostnameVerificationEnabled(boolean httpsHostnameVerificationEnabled)
public int getKeepAliveInterval()
public void setKeepAliveInterval(int keepAliveInterval)
public int getMaxInflight()
public void setMaxInflight(int maxInflight)
public int getMqttVersion()
public void setMqttVersion(int mqttVersion)
public javax.net.SocketFactory getSocketFactory()
public void setSocketFactory(javax.net.SocketFactory socketFactory)
public javax.net.ssl.HostnameVerifier getHostnameVerifier()
public void setHostnameVerifier(javax.net.ssl.HostnameVerifier hostnameVerifier)
public java.util.Properties getSslClientProps()
public void setSslClientProps(java.util.Properties sslClientProps)
public java.util.Properties getCustomWebSocketHeaders()
public void setCustomWebSocketHeaders(java.util.Properties customWebSocketHeaders)