[jboss-cvs] JBossAS SVN: r61452 - trunk/testsuite/src/main/org/jboss/test/jbossmq/test.

[jboss-cvs-commits at lists.jboss.org]

Author: adrian at jboss.org
Date: 2007-03-19 13:19:19 -0400 (Mon, 19 Mar 2007)
New Revision: 61452

Modified:
   trunk/testsuite/src/main/org/jboss/test/jbossmq/test/JBossMQUnitTest.java
Log:
[JBAS-4204] - Need to close the subscriber before unsubscribing

Modified: trunk/testsuite/src/main/org/jboss/test/jbossmq/test/JBossMQUnitTest.java
===================================================================
--- trunk/testsuite/src/main/org/jboss/test/jbossmq/test/JBossMQUnitTest.java	2007-03-19 17:16:06 UTC (rev 61451)
+++ trunk/testsuite/src/main/org/jboss/test/jbossmq/test/JBossMQUnitTest.java	2007-03-19 17:19:19 UTC (rev 61452)
@@ -54,7 +54,7 @@
 import junit.framework.Test;
 import junit.framework.TestSuite;
 
-import org.jboss.logging.Logger;
+import org.apache.log4j.Category;
 import org.jboss.test.JBossTestCase;
 
 import EDU.oswego.cs.dl.util.concurrent.CountDown;
@@ -62,6 +62,9 @@
 /**
  * Basic jms tests.
  *
+ * Some simple tests of spyderMQ
+ *
+ * @author Hiram Chirino <Cojonudo14 at hotmail.com>
  * @author Scott.Stark at jboss.org
  * @author Dimitris.Andreadis at jboss.org
  * @version $Revision$
@@ -109,7 +112,7 @@
       
       return suite;
    }
-   
+
    public JBossMQUnitTest(String name) throws Exception
    {
       super(name);
@@ -243,7 +246,7 @@
       {
          public void run()
          {
-            Logger log = Logger.getLogger(getClass().getName());
+            Category log = Category.getInstance(getClass().getName());
             try
             {
                log.debug("Server Thread Started");
@@ -610,7 +613,7 @@
       {
          public void onMessage(Message msg)
          {
-            Logger log = Logger.getLogger(getClass().getName());
+            Category log = Category.getInstance(getClass().getName());
             log.debug("ML");
             try
             {
@@ -648,7 +651,7 @@
       {
          public void onMessage(Message msg)
          {
-            Logger log = Logger.getLogger(getClass().getName());
+            Category log = Category.getInstance(getClass().getName());
             log.debug("ML 2");
             try
             {
@@ -702,7 +705,7 @@
       {
          public void onMessage(Message mess)
          {
-            Logger log = Logger.getLogger(getClass().getName());
+            Category log = Category.getInstance(getClass().getName());
             log.debug("Processing message");
             try
             {
@@ -724,7 +727,7 @@
       {
          public ServerSession getServerSession()
          {
-            Logger.getLogger(getClass().getName()).debug("Getting server session.");
+            Category.getInstance(getClass().getName()).debug("Getting server session.");
             return new ServerSession()
             {
                public Session getSession()
@@ -733,7 +736,7 @@
                }
                public void start()
                {
-                  Logger.getLogger(getClass().getName()).debug("Starting server session.");
+                  Category.getInstance(getClass().getName()).debug("Starting server session.");
                   session.run();
                }
             };
@@ -1142,6 +1145,7 @@
          assertTrue("Expected message 2", message != null);
          assertTrue("Should get Message2", message.getText().equals("Message2"));
          getLog().debug("Closing the subscriber");
+         subscriber.close();
 
          getLog().debug("Removing the subscription");
          subSession = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);