org.astarteplatform.devicesdk.android

Class AstarteAndroidFailedMessageStorage

java.lang.Object

org.astarteplatform.devicesdk.android.AstarteAndroidFailedMessageStorage

All Implemented Interfaces:

AstarteFailedMessageStorage

public class AstarteAndroidFailedMessageStorage
extends java.lang.Object
implements AstarteFailedMessageStorage

Constructor Summary

Constructors

Constructor and Description
AstarteAndroidFailedMessageStorage(AstarteAndroidFailedMessageDao failedMessageDao)

Method Summary

Modifier and Type	Method and Description
void	ackFirst()
void	insertStored(java.lang.String topic, byte[] payload, int qos)
void	insertStored(java.lang.String topic, byte[] payload, int qos, int relativeExpiry)
void	insertVolatile(java.lang.String topic, byte[] payload, int qos)
void	insertVolatile(java.lang.String topic, byte[] payload, int qos, int relativeExpiry)
boolean	isEmpty()
AstarteFailedMessage	peekFirst()
void	rejectFirst()

Methods inherited from class java.lang.Object

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

Constructor Detail

AstarteAndroidFailedMessageStorage

public AstarteAndroidFailedMessageStorage(AstarteAndroidFailedMessageDao failedMessageDao)

Method Detail

insertVolatile

public void insertVolatile(java.lang.String topic,
                           byte[] payload,
                           int qos)

Specified by:

insertVolatile in interface AstarteFailedMessageStorage

insertVolatile

public void insertVolatile(java.lang.String topic,
                           byte[] payload,
                           int qos,
                           int relativeExpiry)

Specified by:

insertVolatile in interface AstarteFailedMessageStorage

insertStored

public void insertStored(java.lang.String topic,
                         byte[] payload,
                         int qos)
                  throws AstarteTransportException

Specified by:

insertStored in interface AstarteFailedMessageStorage

Throws:

AstarteTransportException

insertStored

public void insertStored(java.lang.String topic,
                         byte[] payload,
                         int qos,
                         int relativeExpiry)
                  throws AstarteTransportException

Specified by:

insertStored in interface AstarteFailedMessageStorage

Throws:

AstarteTransportException

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface AstarteFailedMessageStorage

peekFirst

public AstarteFailedMessage peekFirst()

Specified by:

peekFirst in interface AstarteFailedMessageStorage

ackFirst

public void ackFirst()

Specified by:

ackFirst in interface AstarteFailedMessageStorage

rejectFirst

public void rejectFirst()

Specified by:

rejectFirst in interface AstarteFailedMessageStorage