org.astarteplatform.devicesdk.transport.mqtt

Class AstarteMqttTransport

java.lang.Object

org.astarteplatform.devicesdk.transport.AstarteTransport

org.astarteplatform.devicesdk.transport.mqtt.AstarteMqttTransport

All Implemented Interfaces:

AstarteProtocol, org.eclipse.paho.client.mqttv3.IMqttActionListener

Direct Known Subclasses:

AstarteMqttV1Transport

public abstract class AstarteMqttTransport
extends AstarteTransport
implements org.eclipse.paho.client.mqttv3.IMqttActionListener

Field Summary

Fields

Modifier and Type	Field and Description
protected org.eclipse.paho.client.mqttv3.MqttAsyncClient	m_client

Fields inherited from class org.astarteplatform.devicesdk.transport.AstarteTransport

m_astarteTransportEventListener, m_failedMessageStorage, m_introspectionSent, m_messageListener, m_propertyStorage

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AstarteMqttTransport(AstarteProtocolType type, MqttConnectionInfo connectionInfo)

Method Summary

Modifier and Type	Method and Description
void	connect()
void	disconnect()
MqttConnectionInfo	getConnectionInfo()
boolean	isConnected()
protected abstract void	onConnected(org.eclipse.paho.client.mqttv3.IMqttToken asyncActionToken)
void	onFailure(org.eclipse.paho.client.mqttv3.IMqttToken asyncActionToken, java.lang.Throwable exception)
protected void	setCallback(org.eclipse.paho.client.mqttv3.MqttCallback callback)

Methods inherited from class org.astarteplatform.devicesdk.transport.AstarteTransport

getAstarteProtocolType, getAstarteTransportEventListener, getDevice, getFailedMessageStorage, getMessageListener, getPropertyStorage, removePropertyFromStorage, savePropertyToStorage, sendAggregate, sendIndividualValue, setAstarteTransportEventListener, setDevice, setFailedMessageStorage, setMessageListener, setPropertyStorage

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.eclipse.paho.client.mqttv3.IMqttActionListener

onSuccess

Methods inherited from interface org.astarteplatform.devicesdk.protocol.AstarteProtocol

resendAllProperties, sendAggregate, sendEmptyCache, sendIndividualValue, sendIntrospection

Field Detail

m_client

protected org.eclipse.paho.client.mqttv3.MqttAsyncClient m_client

Constructor Detail

AstarteMqttTransport

protected AstarteMqttTransport(AstarteProtocolType type,
                               MqttConnectionInfo connectionInfo)

Method Detail

setCallback

protected void setCallback(org.eclipse.paho.client.mqttv3.MqttCallback callback)

getConnectionInfo

public MqttConnectionInfo getConnectionInfo()

connect

public void connect()
             throws AstarteTransportException,
                    AstarteCryptoException

Specified by:

connect in class AstarteTransport

Throws:

AstarteTransportException

AstarteCryptoException

disconnect

public void disconnect()
                throws AstarteTransportException

Specified by:

disconnect in class AstarteTransport

Throws:

AstarteTransportException

isConnected

public boolean isConnected()

Specified by:

isConnected in class AstarteTransport

onFailure

public void onFailure(org.eclipse.paho.client.mqttv3.IMqttToken asyncActionToken,
                      java.lang.Throwable exception)

Specified by:

onFailure in interface org.eclipse.paho.client.mqttv3.IMqttActionListener

onConnected

protected abstract void onConnected(org.eclipse.paho.client.mqttv3.IMqttToken asyncActionToken)
                             throws AstarteTransportException

Throws:

AstarteTransportException