fix tests

whummer · whummer · commit e2a0fbaa96ac · 2020-02-25T00:10:31.000+01:00
diff --git a/src/main/java/cloud/localstack/Localstack.java b/src/main/java/cloud/localstack/Localstack.java
@@ -191,7 +191,9 @@ public String getEndpointEC2() {
         return endpointForService(ServiceName.EC2);
     }
 
-    public String getEndpointStepFunctions() { return endpointForService(ServiceName.STEPFUNCTIONS); }
+    public String getEndpointStepFunctions() {
+        return endpointForService(ServiceName.STEPFUNCTIONS);
+    }
 
     public String endpointForService(String serviceName) {
         if (serviceToPortMap == null) {
diff --git a/src/test/java/cloud/localstack/SQSMessagingTest.java b/src/test/java/cloud/localstack/SQSMessagingTest.java
@@ -76,6 +76,11 @@ public void testSendMessage() throws JMSException {
         MessageConsumer consumer = session.createConsumer(queue);
         TextMessage received = (TextMessage) consumer.receive();
         Assert.assertNotNull(received);
+
+        // clean up
+        consumer.close();
+        producer.close();
+        connection.close();
     }
 
     @Test
@@ -169,4 +174,4 @@ public void testSendMultiByteCharactersMessage() throws JMSException {
         final ReceiveMessageResult messageResult = clientSQS.receiveMessage(queueUrl);
         Assert.assertNotNull(messageResult);
     }
-}
+}
diff --git a/src/test/java/cloud/localstack/docker/BasicDockerFunctionalityTest.java b/src/test/java/cloud/localstack/docker/BasicDockerFunctionalityTest.java
@@ -172,6 +172,11 @@ public void testSQS() throws Exception {
         MessageConsumer consumer = session.createConsumer(queue);
         TextMessage received = (TextMessage) consumer.receive();
         Assertions.assertThat(received.getText()).isEqualTo("Hello World!");
+
+        // clean up
+        consumer.close();
+        producer.close();
+        connection.close();
     }
 
     @org.junit.Test
diff --git a/src/test/java/cloud/localstack/docker/DockerOnlySQSFunctionalityTest.java b/src/test/java/cloud/localstack/docker/DockerOnlySQSFunctionalityTest.java
@@ -93,6 +93,11 @@ public void testSQSRunning() throws Exception {
         TextMessage received = (TextMessage) consumer.receive();
 
         Assertions.assertThat(received.getText()).isEqualTo("Hello World!");
+
+        // clean up
+        consumer.close();
+        producer.close();
+        connection.close();
     }
 
     private SQSConnection createSQSConnection() throws Exception {

Original file line number	Diff line number	Diff line change
`@@ -191,7 +191,9 @@ public String getEndpointEC2() {`
`191`	`191`	`return endpointForService(ServiceName.EC2);`
`192`	`192`	`}`
`193`	`193`
`194`		`- public String getEndpointStepFunctions() { return endpointForService(ServiceName.STEPFUNCTIONS); }`
	`194`	`+ public String getEndpointStepFunctions() {`
	`195`	`+ return endpointForService(ServiceName.STEPFUNCTIONS);`
	`196`	`+ }`
`195`	`197`
`196`	`198`	`public String endpointForService(String serviceName) {`
`197`	`199`	`if (serviceToPortMap == null) {`