prepare for 3.6.1 release

Author: James Sörling

docker-compose.yml

@@ -1,7 +1,7 @@
 version: '2'
 services:
   wildfly:
-    image: uvms/wildfly-release:3.6.0
+    image: uvms/wildfly-release:3.6.1
     container_name: wildfly
     ports:
      - "29990:9990"
@@ -18,12 +18,12 @@ services:
      - activemq
     command: ["/opt/jboss/start.sh", "/opt/jboss/wildfly/bin/standalone.sh", "-c", "standalone-uvms.xml", "-b", "0.0.0.0", "-bmanagement", "0.0.0.0", "--debug"]
   postgres:
-    image: uvms/postgres-release:3.6.0
+    image: uvms/postgres-release:3.6.1
     container_name: postgres
     ports: 
      - "25432:5432"
   activemq:
-    image: uvms/activemq:3.6.0
+    image: uvms/activemq:3.6.1
     container_name: activemq
     ports:
      - "18161:8161"

release-test/src/test/java/eu/europa/ec/fisheries/uvms/docker/validation/common/MessageHelper.java

@@ -5,6 +5,7 @@
 import javax.jms.Connection;
 import javax.jms.ConnectionFactory;
 import javax.jms.DeliveryMode;
+import javax.jms.JMSException;
 import javax.jms.Message;
 import javax.jms.MessageConsumer;
 import javax.jms.MessageListener;
@@ -48,7 +49,7 @@ public static Message getMessageResponse(String queueName, final String msg) thr
 
 		return listener.getMessage();
 	}
-	
+
 	public static void sendMessage(String queueName, final String msg) throws Exception {
 		String responseQueueName = queueName + "Response" + UUID.randomUUID().toString().replaceAll("-", "");
 
@@ -67,8 +68,9 @@ public static void sendMessage(String queueName, final String msg) throws Except
 		createTextMessage.setJMSReplyTo(responseQueue);
 		messageProducer.send(createTextMessage);
 		session.close();
+		connection.close();
 	}
-	
+
 
 	private static void setupResponseConsumer(String queueName, ResponseQueueMessageListener listener) throws Exception {
 		Connection consumerConnection = connectionFactory.createConnection();
@@ -78,16 +80,28 @@ private static void setupResponseConsumer(String queueName, ResponseQueueMessage
 		MessageConsumer consumer = session.createConsumer(responseQueue);
 
 		consumer.setMessageListener(listener);
+		listener.setConsumerConnection(consumerConnection);
 		consumerConnection.start();
 
 	}
 
 	private static class ResponseQueueMessageListener implements MessageListener {
 		private volatile Message message = null;
+		private Connection consumerConnection;
+
+
+		public void setConsumerConnection(Connection consumerConnection) {
+			this.consumerConnection = consumerConnection;
+		}
 
 		@Override
 		public void onMessage(Message message) {
 			this.message = message;
+			try {
+				this.consumerConnection.close();
+			} catch (JMSException e) {
+				e.printStackTrace();
+			}
 		}
 
 		public Message getMessage() {