feat #12 受信キュー内のメッセージ数を取得

TodorokiKohei · Jul 11, 2023 · d933c54 · d933c54
1 parent 4112e66
commit d933c54
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/...paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/internal/ClientComms.java b/...paho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/internal/ClientComms.java
@@ -973,9 +973,13 @@ public int getActualInFlight() {
 
 	public boolean doesSubscriptionIdentifierExist(int subscriptionIdentifier) {
 		return this.callback.doesSubscriptionIdentifierExist(subscriptionIdentifier);
+	}
 
 	public void resizeReceiverQueueSize(int size){
 		callback.resizeQueueSize(size);
 	}
 
+	public int getNumberOfMsgsUnprocessed(){
+		return callback.getNumberOfMsgsInQueue();
+	}
 }
diff --git a/...ho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/internal/CommsCallback.java b/...ho.mqttv5.client/src/main/java/org/eclipse/paho/mqttv5/client/internal/CommsCallback.java
@@ -675,7 +675,7 @@ public void resizeQueueSize(int size) {
 		messageQueue.ensureCapacity(size);
 	}
 
-	public int getNumberOfMsgsInQueue(){
+	public int getNumberOfMsgsInQueue() {
 		return messageQueue.size();
 	}