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