org.astarteplatform.devicesdk.transport.mqtt

Class AstarteMqttV1Transport

java.lang.Object

org.astarteplatform.devicesdk.transport.AstarteTransport

org.astarteplatform.devicesdk.transport.mqtt.AstarteMqttTransport

org.astarteplatform.devicesdk.transport.mqtt.AstarteMqttV1Transport

All Implemented Interfaces:

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

public class AstarteMqttV1Transport
extends AstarteMqttTransport
implements org.eclipse.paho.client.mqttv3.MqttCallbackExtended

Field Summary

Fields inherited from class org.astarteplatform.devicesdk.transport.mqtt.AstarteMqttTransport

m_client

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

m_astarteTransportEventListener, m_failedMessageStorage, m_introspectionSent, m_messageListener, m_propertyStorage

Constructor Summary

Constructors

Constructor and Description
AstarteMqttV1Transport(MutualSSLAuthenticationMqttConnectionInfo connectionInfo)

Method Summary

Modifier and Type	Method and Description
void	connectComplete(boolean reconnect, java.lang.String serverURI)
void	connectionLost(java.lang.Throwable cause)
void	deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)
void	messageArrived(java.lang.String topic, org.eclipse.paho.client.mqttv3.MqttMessage message)
protected void	onConnected(org.eclipse.paho.client.mqttv3.IMqttToken asyncActionToken)
void	onSuccess(org.eclipse.paho.client.mqttv3.IMqttToken asyncActionToken)
void	resendAllProperties()
void	retryFailedMessages()
void	sendAggregate(AstarteAggregateDatastreamInterface astarteInterface, java.lang.String path, java.util.Map<java.lang.String,java.lang.Object> value, org.joda.time.DateTime timestamp)
void	sendEmptyCache()
void	sendIndividualValue(AstarteInterface astarteInterface, java.lang.String path, java.lang.Object value, org.joda.time.DateTime timestamp)
void	sendIntrospection()
void	setFailedMessageStorage(AstarteFailedMessageStorage failedMessageStorage)

Methods inherited from class org.astarteplatform.devicesdk.transport.mqtt.AstarteMqttTransport

connect, disconnect, getConnectionInfo, isConnected, onFailure, setCallback

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

AstarteMqttV1Transport

public AstarteMqttV1Transport(MutualSSLAuthenticationMqttConnectionInfo connectionInfo)

Method Detail

connectComplete

public void connectComplete(boolean reconnect,
                            java.lang.String serverURI)

Specified by:

connectComplete in interface org.eclipse.paho.client.mqttv3.MqttCallbackExtended

connectionLost

public void connectionLost(java.lang.Throwable cause)

Specified by:

connectionLost in interface org.eclipse.paho.client.mqttv3.MqttCallback

messageArrived

public void messageArrived(java.lang.String topic,
                           org.eclipse.paho.client.mqttv3.MqttMessage message)
                    throws AstarteTransportException

Specified by:

messageArrived in interface org.eclipse.paho.client.mqttv3.MqttCallback

Throws:

AstarteTransportException

deliveryComplete

public void deliveryComplete(org.eclipse.paho.client.mqttv3.IMqttDeliveryToken token)

Specified by:

deliveryComplete in interface org.eclipse.paho.client.mqttv3.MqttCallback

setFailedMessageStorage

public void setFailedMessageStorage(AstarteFailedMessageStorage failedMessageStorage)

Overrides:

setFailedMessageStorage in class AstarteTransport

sendIntrospection

public void sendIntrospection()
                       throws AstarteTransportException

Specified by:

sendIntrospection in interface AstarteProtocol

Throws:

AstarteTransportException

sendEmptyCache

public void sendEmptyCache()
                    throws AstarteTransportException

Specified by:

sendEmptyCache in interface AstarteProtocol

Throws:

AstarteTransportException

resendAllProperties

public void resendAllProperties()
                         throws AstarteTransportException

Specified by:

resendAllProperties in interface AstarteProtocol

Throws:

AstarteTransportException

retryFailedMessages

public void retryFailedMessages()
                         throws AstarteTransportException

Throws:

AstarteTransportException

sendIndividualValue

public void sendIndividualValue(AstarteInterface astarteInterface,
                                java.lang.String path,
                                java.lang.Object value,
                                org.joda.time.DateTime timestamp)
                         throws AstarteTransportException

Specified by:

sendIndividualValue in interface AstarteProtocol

Throws:

AstarteTransportException

sendAggregate

public void sendAggregate(AstarteAggregateDatastreamInterface astarteInterface,
                          java.lang.String path,
                          java.util.Map<java.lang.String,java.lang.Object> value,
                          org.joda.time.DateTime timestamp)
                   throws AstarteTransportException

Specified by:

sendAggregate in interface AstarteProtocol

Throws:

AstarteTransportException

onSuccess

public void onSuccess(org.eclipse.paho.client.mqttv3.IMqttToken asyncActionToken)

Specified by:

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

onConnected

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

Specified by:

onConnected in class AstarteMqttTransport

Throws:

AstarteTransportException