Skip to content

Commit d11139f

Browse files
author
Ranjan Dasgupta
authored
Merge pull request #771 from ogis-yamazaki/missing_interface_method
Add missing interface methods.
2 parents 28eed43 + f502316 commit d11139f

1 file changed

Lines changed: 43 additions & 0 deletions

File tree

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/IMqttAsyncClient.java

Lines changed: 43 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -887,6 +887,49 @@ IMqttToken unsubscribe(String[] topicFilters, Object userContext, IMqttActionLis
887887
*/
888888
void messageArrivedComplete(int messageId, int qos) throws MqttException;
889889

890+
891+
/**
892+
* Sets the DisconnectedBufferOptions for this client
893+
*
894+
* @param bufferOpts
895+
* the {@link DisconnectedBufferOptions}
896+
*/
897+
void setBufferOpts(DisconnectedBufferOptions bufferOpts);
898+
899+
/**
900+
* Returns the number of messages in the Disconnected Message Buffer
901+
*
902+
* @return Count of messages in the buffer
903+
*/
904+
int getBufferedMessageCount();
905+
906+
/**
907+
* Returns a message from the Disconnected Message Buffer
908+
*
909+
* @param bufferIndex
910+
* the index of the message to be retrieved.
911+
* @return the message located at the bufferIndex
912+
*/
913+
MqttMessage getBufferedMessage(int bufferIndex);
914+
915+
/**
916+
* Deletes a message from the Disconnected Message Buffer
917+
*
918+
* @param bufferIndex
919+
* the index of the message to be deleted.
920+
*/
921+
void deleteBufferedMessage(int bufferIndex);
922+
923+
/**
924+
* Returns the current number of outgoing in-flight messages being sent by the
925+
* client. Note that this number cannot be guaranteed to be 100% accurate as
926+
* some messages may have been sent or queued in the time taken for this method
927+
* to return.
928+
*
929+
* @return the current number of in-flight messages.
930+
*/
931+
int getInFlightMessageCount();
932+
890933
/**
891934
* Close the client
892935
* Releases all resource associated with the client. After the client has

0 commit comments

Comments
 (0)