public class DisconnectedMessageBuffer
extends java.lang.Object
implements java.lang.Runnable
Constructor and Description |
---|
DisconnectedMessageBuffer(DisconnectedBufferOptions options) |
Modifier and Type | Method and Description |
---|---|
void |
deleteMessage(int messageIndex)
Removes a message from the buffer
|
BufferedMessage |
getMessage(int messageIndex)
Retrieves a message from the buffer at the given index.
|
int |
getMessageCount()
Returns the number of messages currently in the buffer
|
void |
putMessage(MqttWireMessage message,
MqttToken token)
This will add a new message to the offline buffer,
if the buffer is full and deleteOldestMessages is enabled
then the 0th item in the buffer will be deleted and the
new message will be added.
|
void |
run()
Flushes the buffer of messages into an open connection
|
void |
setPublishCallback(IDisconnectedBufferCallback callback) |
public DisconnectedMessageBuffer(DisconnectedBufferOptions options)
public void putMessage(MqttWireMessage message, MqttToken token) throws MqttException
message
- MqttException
public BufferedMessage getMessage(int messageIndex)
messageIndex
- MqttException
public void deleteMessage(int messageIndex)
messageIndex
- MqttException
public int getMessageCount()
MqttException
public void run()
run
in interface java.lang.Runnable
public void setPublishCallback(IDisconnectedBufferCallback callback)