public interface AstarteFailedMessageStorage
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() |
void insertVolatile(java.lang.String topic, byte[] payload, int qos)
void insertVolatile(java.lang.String topic, byte[] payload, int qos, int relativeExpiry)
void insertStored(java.lang.String topic, byte[] payload, int qos) throws AstarteTransportException
AstarteTransportException
void insertStored(java.lang.String topic, byte[] payload, int qos, int relativeExpiry) throws AstarteTransportException
AstarteTransportException
boolean isEmpty()
AstarteFailedMessage peekFirst()
void ackFirst() throws AstarteTransportException
AstarteTransportException
void rejectFirst() throws AstarteTransportException
AstarteTransportException