Release 2.4.x

example-context/example-service/example-it/pom.xml

@@ -191,6 +191,12 @@
             <version>${event-store.version}</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>uk.gov.justice.event-store</groupId>
+            <artifactId>event-store-management-command-handler-extension</artifactId>
+            <version>${event-store.version}</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 
     <build>

example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/CatchupPerformanceIT.java

@@ -25,9 +25,6 @@
 import uk.gov.justice.services.test.utils.core.messaging.Poller;
 import uk.gov.justice.services.test.utils.persistence.DatabaseCleaner;
 
-import java.sql.Connection;
-import java.sql.PreparedStatement;
-import java.sql.ResultSet;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Optional;

example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/MultipleEventListenerCakeShopIT.java

@@ -18,6 +18,7 @@
 import uk.gov.justice.services.example.cakeshop.it.helpers.ApiResponse;
 import uk.gov.justice.services.example.cakeshop.it.helpers.CommandSender;
 import uk.gov.justice.services.example.cakeshop.it.helpers.EventFactory;
+import uk.gov.justice.services.example.cakeshop.it.helpers.EventSender;
 import uk.gov.justice.services.example.cakeshop.it.helpers.JmsBootstrapper;
 import uk.gov.justice.services.example.cakeshop.it.helpers.Querier;
 import uk.gov.justice.services.example.cakeshop.it.helpers.RestEasyClientFactory;
@@ -26,10 +27,8 @@
 import java.util.UUID;
 
 import javax.jms.MessageConsumer;
-import javax.jms.MessageProducer;
 import javax.jms.Session;
 import javax.jms.TextMessage;
-import javax.jms.Topic;
 import javax.json.JsonObject;
 import javax.ws.rs.client.Client;
 
@@ -44,6 +43,7 @@ public class MultipleEventListenerCakeShopIT {
 
     private final EventFactory eventFactory = new EventFactory();
     private final JmsBootstrapper jmsBootstrapper = new JmsBootstrapper();
+    private final EventSender eventSender = new EventSender();
 
     private Client client;
     private Querier querier;
@@ -69,12 +69,7 @@ public void shouldReturnRecipeFromOtherEventListener() throws Exception {
 
         //adding 1 recipe as other event
         final UUID recipeId2 = randomUUID();
-
-        try (final Session jmsSession = jmsBootstrapper.jmsSession()) {
-            final Topic topic = jmsSession.createTopic("other.event");
-
-            try (final MessageProducer producer = jmsSession.createProducer(topic);) {
-
+            final String topicName = "other.event";
                 final JsonObject jsonObject = createObjectBuilder()
                         .add("recipeId", recipeId2.toString())
                         .add("name", "Chocolate muffin")
@@ -95,15 +90,7 @@ public void shouldReturnRecipeFromOtherEventListener() throws Exception {
                                 .build(),
                         jsonObject);
 
-                @SuppressWarnings("deprecation") final String json = jsonEnvelope.toDebugStringPrettyPrint();
-                final TextMessage message = jmsSession.createTextMessage();
-
-                message.setText(json);
-                message.setStringProperty("CPPNAME", "other.recipe-added");
-
-                producer.send(message);
-            }
-        }
+        eventSender.sendToTopic(jsonEnvelope, topicName);
 
         await().until(() -> {
             final String responseBody = querier.recipesQueryResult(singletonList(new BasicNameValuePair("pagesize", "30"))).body();

example-context/example-service/example-it/src/test/java/uk/gov/justice/services/example/cakeshop/it/helpers/EventSender.java

@@ -0,0 +1,31 @@
+package uk.gov.justice.services.example.cakeshop.it.helpers;
+
+import uk.gov.justice.services.messaging.JsonEnvelope;
+
+import javax.jms.JMSException;
+import javax.jms.MessageProducer;
+import javax.jms.Session;
+import javax.jms.TextMessage;
+import javax.jms.Topic;
+
+public class EventSender {
+
+    private final JmsBootstrapper jmsBootstrapper = new JmsBootstrapper();
+
+    public void sendToTopic(final JsonEnvelope jsonEnvelope, final String topicName) throws JMSException {
+        try (final Session jmsSession = jmsBootstrapper.jmsSession()) {
+            final Topic topic = jmsSession.createTopic(topicName);
+
+            try (final MessageProducer producer = jmsSession.createProducer(topic);) {
+
+                @SuppressWarnings("deprecation") final String json = jsonEnvelope.toDebugStringPrettyPrint();
+                final TextMessage message = jmsSession.createTextMessage();
+
+                message.setText(json);
+                message.setStringProperty("CPPNAME", jsonEnvelope.metadata().name());
+
+                producer.send(message);
+            }
+        }
+    }
+}

example-context/example-service/example-it/src/test/resources/wildfly-config/standalone-single.xml

@@ -166,6 +166,8 @@
                 <managed-executor-services>
                     <managed-executor-service name="default"
                                               jndi-name="java:jboss/ee/concurrency/executor/default"
+                                              core-threads="20"
+                                              max-threads="250"
                                               context-service="default" hung-task-threshold="60000"
                                               keepalive-time="5000"/>
                 </managed-executor-services>

example-context/example-service/example-single/pom.xml

@@ -85,6 +85,11 @@
             <artifactId>event-store-management-commands</artifactId>
             <version>${event-store.version}</version>
         </dependency>
+        <dependency>
+            <groupId>uk.gov.justice.event-store</groupId>
+            <artifactId>event-store-management-command-handler-extension</artifactId>
+            <version>${event-store.version}</version>
+        </dependency>
 
         <!-- Test Dependencies -->
         <dependency>

pom.xml

@@ -33,7 +33,7 @@
 
         <framework-api.version>4.1.0</framework-api.version>
         <framework.version>6.4.0</framework.version>
-        <event-store.version>2.4.2</event-store.version>
+        <event-store.version>2.4.9</event-store.version>
         <framework-generators.version>2.4.0</framework-generators.version>
         <file.service.version>1.17.12</file.service.version>