org.astarteplatform.devicesdk.generic

Class AstarteGenericFailedMessageStorage

java.lang.Object

org.astarteplatform.devicesdk.generic.AstarteGenericFailedMessageStorage

All Implemented Interfaces:

AstarteFailedMessageStorage

public class AstarteGenericFailedMessageStorage
extends java.lang.Object
implements AstarteFailedMessageStorage

Constructor Summary

Constructors

Constructor and Description
AstarteGenericFailedMessageStorage(com.j256.ormlite.dao.Dao<AstarteGenericFailedMessage,java.lang.Long> 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

AstarteGenericFailedMessageStorage

public AstarteGenericFailedMessageStorage(com.j256.ormlite.dao.Dao<AstarteGenericFailedMessage,java.lang.Long> failedMessageDao)
                                   throws java.sql.SQLException

Throws:

java.sql.SQLException

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()
              throws AstarteTransportException

Specified by:

ackFirst in interface AstarteFailedMessageStorage

Throws:

AstarteTransportException

rejectFirst

public void rejectFirst()
                 throws AstarteTransportException

Specified by:

rejectFirst in interface AstarteFailedMessageStorage

Throws:

AstarteTransportException