• Home
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
1 package software.amazon.awssdk.crt.mqtt;
2 
3 /**
4  * Simple statistics about the current state of the connection's queue of operations
5  */
6 public class MqttClientConnectionOperationStatistics {
7 
8     private long incompleteOperationCount;
9     private long incompleteOperationSize;
10     private long unackedOperationCount;
11     private long unackedOperationSize;
12 
MqttClientConnectionOperationStatistics()13     public MqttClientConnectionOperationStatistics() {}
14 
15     /**
16      * Returns the total number of operations submitted to the connection that have not yet been completed.
17      * Note: Unacked operations are a subset of this.
18      * @return Total number of operations submitted to the connection that have not yet been completed
19      */
getIncompleteOperationCount()20     public long getIncompleteOperationCount() {
21         return incompleteOperationCount;
22     }
23 
24     /**
25      * Returns the total packet size of operations submitted to the connection that have not yet been completed.
26      * Note: Unacked operations are a subset of this.
27      * @return Total packet size of operations submitted to the connection that have not yet been completed
28      */
getIncompleteOperationSize()29     public long getIncompleteOperationSize() {
30         return incompleteOperationSize;
31     }
32 
33     /**
34      * Returns the total number of operations that have been sent and are waiting for a corresponding ACK before
35      * they can be completed.
36      * @return Total number of operations that have been sent and are waiting for a corresponding ACK
37      */
getUnackedOperationCount()38     public long getUnackedOperationCount() {
39         return unackedOperationCount;
40     }
41 
42     /**
43      * Returns the total packet size of operations that have been sent and are waiting for a corresponding ACK before
44      * they can be completed.
45      * @return Total packet size of operations that have been sent and are waiting for a corresponding ACK
46      */
getUnackedOperationSize()47     public long getUnackedOperationSize() {
48         return unackedOperationSize;
49     }
50 }
51