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

public class AstarteMqttV1Transport
extends AstarteMqttTransport

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
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, 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

setFailedMessageStorage

public void setFailedMessageStorage(AstarteFailedMessageStorage failedMessageStorage)

Overrides:

setFailedMessageStorage in class AstarteTransport

sendIntrospection

public void sendIntrospection()
                       throws AstarteTransportException

Throws:

AstarteTransportException

sendEmptyCache

public void sendEmptyCache()
                    throws AstarteTransportException

Throws:

AstarteTransportException

resendAllProperties

public void resendAllProperties()
                         throws AstarteTransportException

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

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

Throws:

AstarteTransportException

onSuccess

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

onConnected

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

Specified by:

onConnected in class AstarteMqttTransport

Throws:

AstarteTransportException