Merge branch 'release/12.5.4'

iitsoftware · Mar 4, 2023 · 3ff5c0d · 3ff5c0d
2 parents 809ea47 + eb8e282
commit 3ff5c0d
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 3 deletions.
diff --git a/pom.xml b/pom.xml
@@ -7,7 +7,7 @@
 
   <groupId>com.swiftmq</groupId>
   <artifactId>swiftmq-client</artifactId>
-  <version>12.5.3</version>
+  <version>12.5.4</version>
 
   <name>SwiftMQ Client</name>
   <description>Client for SwiftMQ Messaging System with JMS, AMQP 1.0 and file transfer over JMS.</description>

diff --git a/src/main/java/com/swiftmq/mgmt/Entity.java b/src/main/java/com/swiftmq/mgmt/Entity.java
@@ -850,7 +850,7 @@ public void removeEntities() {
      */
     public void removeDynamicEntity(Object dynamicObject) {
         Entity entity = null;
-        lock.readLock().lock();
+        lock.writeLock().lock();
         try {
             for (Iterator iter = entities.entrySet().iterator(); iter.hasNext(); ) {
                 entity = (Entity) ((Map.Entry) iter.next()).getValue();
@@ -862,7 +862,7 @@ public void removeDynamicEntity(Object dynamicObject) {
                 }
             }
         } finally {
-            lock.readLock().unlock();
+            lock.writeLock().unlock();
         }
 
         if (entity != null)

diff --git a/src/main/java/com/swiftmq/swiftlet/queue/AbstractQueue.java b/src/main/java/com/swiftmq/swiftlet/queue/AbstractQueue.java
@@ -518,6 +518,15 @@ public int getProducedTotal() {
     public void resetCounters() {
     }
 
+    /**
+     * Returns the average queue latency and resets it
+     *
+     * @return average queue latency
+     */
+    public long getAndResetAverageLatency() {
+        return (0);
+    }
+
     public int getMonitorAlertThreshold() {
         return -1;
     }