org.astarteplatform.devicesdk.transport

Class AstarteTransport

java.lang.Object

org.astarteplatform.devicesdk.transport.AstarteTransport

All Implemented Interfaces:

AstarteProtocol

Direct Known Subclasses:

AstarteMqttTransport

public abstract class AstarteTransport
extends java.lang.Object
implements AstarteProtocol

Field Summary

Fields

Modifier and Type	Field and Description
protected AstarteTransportEventListener	m_astarteTransportEventListener
protected AstarteFailedMessageStorage	m_failedMessageStorage
protected boolean	m_introspectionSent
protected AstarteMessageListener	m_messageListener
protected AstartePropertyStorage	m_propertyStorage

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AstarteTransport(AstarteProtocolType type)

Method Summary

Modifier and Type	Method and Description
abstract void	connect()
abstract void	disconnect()
AstarteProtocolType	getAstarteProtocolType()
AstarteTransportEventListener	getAstarteTransportEventListener()
AstarteDevice	getDevice()
AstarteFailedMessageStorage	getFailedMessageStorage()
AstarteMessageListener	getMessageListener()
AstartePropertyStorage	getPropertyStorage()
abstract boolean	isConnected()
protected void	removePropertyFromStorage(java.lang.String interfaceName, java.lang.String path)
protected void	savePropertyToStorage(java.lang.String interfaceName, java.lang.String path, java.lang.Object value)
void	sendAggregate(AstarteAggregateDatastreamInterface astarteInterface, java.lang.String path, java.util.Map<java.lang.String,java.lang.Object> value)
void	sendIndividualValue(AstarteInterface astarteInterface, java.lang.String path, java.lang.Object value)
void	setAstarteTransportEventListener(AstarteTransportEventListener m_astarteTransportEventListener)
void	setDevice(AstarteDevice device)
void	setFailedMessageStorage(AstarteFailedMessageStorage failedMessageStorage)
void	setMessageListener(AstarteMessageListener messageListener)
void	setPropertyStorage(AstartePropertyStorage m_propertyStorage)

Methods inherited from class java.lang.Object

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

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

resendAllProperties, sendAggregate, sendEmptyCache, sendIndividualValue, sendIntrospection

Field Detail

m_introspectionSent

protected boolean m_introspectionSent

m_propertyStorage

protected AstartePropertyStorage m_propertyStorage

m_failedMessageStorage

protected AstarteFailedMessageStorage m_failedMessageStorage

m_messageListener

protected AstarteMessageListener m_messageListener

m_astarteTransportEventListener

protected AstarteTransportEventListener m_astarteTransportEventListener

Constructor Detail

AstarteTransport

protected AstarteTransport(AstarteProtocolType type)

Method Detail

getAstarteProtocolType

public AstarteProtocolType getAstarteProtocolType()

Specified by:

getAstarteProtocolType in interface AstarteProtocol

getDevice

public AstarteDevice getDevice()

setDevice

public void setDevice(AstarteDevice device)

getMessageListener

public AstarteMessageListener getMessageListener()

setMessageListener

public void setMessageListener(AstarteMessageListener messageListener)

getPropertyStorage

public AstartePropertyStorage getPropertyStorage()

setPropertyStorage

public void setPropertyStorage(AstartePropertyStorage m_propertyStorage)

getFailedMessageStorage

public AstarteFailedMessageStorage getFailedMessageStorage()

setFailedMessageStorage

public void setFailedMessageStorage(AstarteFailedMessageStorage failedMessageStorage)

getAstarteTransportEventListener

public AstarteTransportEventListener getAstarteTransportEventListener()

setAstarteTransportEventListener

public void setAstarteTransportEventListener(AstarteTransportEventListener m_astarteTransportEventListener)

connect

public abstract void connect()
                      throws AstarteTransportException,
                             AstarteCryptoException

Throws:

AstarteTransportException

AstarteCryptoException

disconnect

public abstract void disconnect()
                         throws AstarteTransportException

Throws:

AstarteTransportException

isConnected

public abstract boolean isConnected()

sendIndividualValue

public void sendIndividualValue(AstarteInterface astarteInterface,
                                java.lang.String path,
                                java.lang.Object value)
                         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)
                   throws AstarteTransportException

Specified by:

sendAggregate in interface AstarteProtocol

Throws:

AstarteTransportException

savePropertyToStorage

protected void savePropertyToStorage(java.lang.String interfaceName,
                                     java.lang.String path,
                                     java.lang.Object value)
                              throws AstartePropertyStorageException

Throws:

AstartePropertyStorageException

removePropertyFromStorage

protected void removePropertyFromStorage(java.lang.String interfaceName,
                                         java.lang.String path)
                                  throws AstartePropertyStorageException

Throws:

AstartePropertyStorageException