org.astarteplatform.devicesdk.protocol

Class AstarteDeviceAggregateDatastreamInterface

java.lang.Object

org.astarteplatform.devicesdk.protocol.AstarteInterface

org.astarteplatform.devicesdk.protocol.AstarteDatastreamInterface

org.astarteplatform.devicesdk.protocol.AstarteAggregateDatastreamInterface

org.astarteplatform.devicesdk.protocol.AstarteDeviceAggregateDatastreamInterface

All Implemented Interfaces:

AstarteAggregateDataStreamer

public class AstarteDeviceAggregateDatastreamInterface
extends AstarteAggregateDatastreamInterface
implements AstarteAggregateDataStreamer

Constructor Summary

Constructors

Constructor and Description
AstarteDeviceAggregateDatastreamInterface()

Method Summary

Modifier and Type	Method and Description
void	streamData(java.lang.String path, java.util.Map<java.lang.String,java.lang.Object> payload)
void	streamData(java.lang.String path, java.util.Map<java.lang.String,java.lang.Object> payload, org.joda.time.DateTime timestamp)
void	validatePayload(java.lang.String path, java.util.Map<java.lang.String,java.lang.Object> payload, org.joda.time.DateTime timestamp)

Methods inherited from class org.astarteplatform.devicesdk.protocol.AstarteAggregateDatastreamInterface

isExplicitTimestamp

Methods inherited from class org.astarteplatform.devicesdk.protocol.AstarteInterface

findMappingInInterface, fromJSON, getAstarteTransport, getInterfaceName, getMajorVersion, getMappings, getMinorVersion, isPathCompatibleWithMapping, setAstarteTransport, validatePayload

Methods inherited from class java.lang.Object

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

Constructor Detail

AstarteDeviceAggregateDatastreamInterface

public AstarteDeviceAggregateDatastreamInterface()

Method Detail

streamData

public void streamData(java.lang.String path,
                       java.util.Map<java.lang.String,java.lang.Object> payload)
                throws AstarteTransportException,
                       AstarteInvalidValueException,
                       AstarteInterfaceMappingNotFoundException

Specified by:

streamData in interface AstarteAggregateDataStreamer

Throws:

AstarteTransportException

AstarteInvalidValueException

AstarteInterfaceMappingNotFoundException

streamData

public void streamData(java.lang.String path,
                       java.util.Map<java.lang.String,java.lang.Object> payload,
                       org.joda.time.DateTime timestamp)
                throws AstarteTransportException,
                       AstarteInvalidValueException,
                       AstarteInterfaceMappingNotFoundException

Specified by:

streamData in interface AstarteAggregateDataStreamer

Throws:

AstarteTransportException

AstarteInvalidValueException

AstarteInterfaceMappingNotFoundException

validatePayload

public void validatePayload(java.lang.String path,
                            java.util.Map<java.lang.String,java.lang.Object> payload,
                            org.joda.time.DateTime timestamp)
                     throws AstarteInvalidValueException,
                            AstarteInterfaceMappingNotFoundException

Throws:

AstarteInvalidValueException

AstarteInterfaceMappingNotFoundException