Added queue statistics for retry and failures

Author: clorenz

README.md

@@ -15,15 +15,15 @@ Maven:
 <dependency>
   <groupId>de.digitalcollections.flusswerk</groupId>
   <artifactId>dc-flusswerk-engine</artifactId>
-  <version>2.0.0</version>
+  <version>2.0.1</version>
 </dependency>
 ```
 
 Gradle:
 
 ```groovy
 dependencies {
-    compile group: 'de.digitalcollections.flusswerk', name: 'dc-flusswerk-engine', version: '2.0.0'
+    compile group: 'de.digitalcollections.flusswerk', name: 'dc-flusswerk-engine', version: '2.0.1'
 }
 ``` 
 

bdd/pom.xml

@@ -3,7 +3,7 @@
   <parent>
     <artifactId>dc-flusswerk-parent</artifactId>
     <groupId>de.digitalcollections.flusswerk</groupId>
-    <version>2.0.1-SNAPSHOT</version>
+    <version>2.0.1</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 

engine/pom.xml

@@ -4,7 +4,7 @@
   <parent>
     <groupId>de.digitalcollections.flusswerk</groupId>
     <artifactId>dc-flusswerk-parent</artifactId>
-    <version>2.0.1-SNAPSHOT</version>
+    <version>2.0.1</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 

engine/src/main/java/de/digitalcollections/flusswerk/engine/messagebroker/MessageBroker.java

@@ -197,6 +197,24 @@ public Map<String, Long> getMessageCounts() throws IOException {
     return result;
   }
 
+  public Map<String, Long> getFailedMessageCounts() throws IOException {
+    Map<String, Long> result = new HashMap<>();
+    for (String inputQueue : routingConfig.getReadFrom()) {
+      String queue = routingConfig.getFailurePolicy(inputQueue).getFailedRoutingKey();
+      result.put(queue, rabbitClient.getMessageCount(queue));
+    }
+    return result;
+  }
+
+  public Map<String, Long> getRetryMessageCounts() throws IOException {
+    Map<String, Long> result = new HashMap<>();
+    for (String inputQueue : routingConfig.getReadFrom()) {
+      String queue = routingConfig.getFailurePolicy(inputQueue).getRetryRoutingKey();
+      result.put(queue, rabbitClient.getMessageCount(queue));
+    }
+    return result;
+  }
+
   public boolean isConnectionOk() {
     return rabbitClient.isChannelAvailable() && rabbitClient.isConnectionOk();
   }

examples/pom.xml

@@ -5,7 +5,7 @@
   <parent>
     <groupId>de.digitalcollections.flusswerk</groupId>
     <artifactId>dc-flusswerk-parent</artifactId>
-    <version>2.0.1-SNAPSHOT</version>
+    <version>2.0.1</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 

pom.xml

@@ -4,7 +4,7 @@
 
   <groupId>de.digitalcollections.flusswerk</groupId>
   <artifactId>dc-flusswerk-parent</artifactId>
-  <version>2.0.1-SNAPSHOT</version>
+  <version>2.0.1</version>
   <packaging>pom</packaging>
 
   <name>DigitalCollections: Flusswerk</name>