[tomee] 02/02: Fixed ProperConnectionShutdownTest. Uncommented code due to AMQ-6051 fix.

[radcortez]

This is an automated email from the ASF dual-hosted git repository.

radcortez pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/tomee.git

commit 5f6c09e834130a16ccb48b68c9675ce23564ea3c
Author: Roberto Cortez <radcor...@yahoo.com>
AuthorDate: Mon Jan 28 16:37:56 2019 +0000

    Fixed ProperConnectionShutdownTest. Uncommented code due to AMQ-6051 fix.
---
 .../resource/activemq/ProperConnectionShutdownTest.java     | 13 +++----------
 1 file changed, 3 insertions(+), 10 deletions(-)

diff --git 
a/container/openejb-core/src/test/java/org/apache/openejb/resource/activemq/ProperConnectionShutdownTest.java
 
b/container/openejb-core/src/test/java/org/apache/openejb/resource/activemq/ProperConnectionShutdownTest.java
index 53d14e4..b11c2c0 100644
--- 
a/container/openejb-core/src/test/java/org/apache/openejb/resource/activemq/ProperConnectionShutdownTest.java
+++ 
b/container/openejb-core/src/test/java/org/apache/openejb/resource/activemq/ProperConnectionShutdownTest.java
@@ -26,7 +26,6 @@ import org.apache.openejb.testing.Module;
 import org.apache.openejb.testng.PropertiesBuilder;
 import org.apache.openejb.util.Join;
 import org.apache.openejb.util.NetworkUtil;
-import org.junit.Ignore;
 import org.junit.Test;
 import org.junit.runners.model.Statement;
 
@@ -71,16 +70,10 @@ public class ProperConnectionShutdownTest {
                 assertEquals(messages.receiveMessage(), "How are you?");
                 assertEquals(messages.receiveMessage(), "Still spinning?");
 
-                /* TODO: activate it when AMQ-6051 is fixed
-
                 // all worked, now hold a connection
-                new Thread(new Runnable() { // not daemon!
-                    @Override
-                    public void run() {
-                        messages.blockConnection(); // oops, I forgot to close 
it
-                    }
-                }).start();
-                 */
+                // not daemon!
+                // oops, I forgot to close it
+                new Thread(messages::blockConnection).start();
             }
         };
         new DeployApplication(this, testInContainer, new 
ApplicationComposers(this)).evaluate();