public class AstarteServerAggregateDatastreamInterface extends AstarteAggregateDatastreamInterface implements AstarteServerValueBuilder, AstarteServerValuePublisher
Modifier and Type | Method and Description |
---|---|
void |
addListener(AstarteAggregateDatastreamEventListener listener) |
AstarteServerValue |
build(java.lang.String interfacePath,
java.lang.Object serverValue,
org.joda.time.DateTime timestamp) |
java.util.Collection<AstarteAggregateDatastreamEventListener> |
getAllListeners() |
void |
publish(AstarteServerValue payload) |
void |
removeListener(AstarteAggregateDatastreamEventListener listener) |
isExplicitTimestamp
findMappingInInterface, fromJSON, getAstarteTransport, getInterfaceName, getMajorVersion, getMappings, getMinorVersion, isPathCompatibleWithMapping, setAstarteTransport, validatePayload
public void addListener(AstarteAggregateDatastreamEventListener listener)
public void removeListener(AstarteAggregateDatastreamEventListener listener)
public java.util.Collection<AstarteAggregateDatastreamEventListener> getAllListeners()
public AstarteServerValue build(java.lang.String interfacePath, java.lang.Object serverValue, org.joda.time.DateTime timestamp)
build
in interface AstarteServerValueBuilder
public void publish(AstarteServerValue payload)
publish
in interface AstarteServerValuePublisher