[hornetq-commits] JBoss hornetq SVN: r8509 - in trunk: tests/src/org/hornetq/tests/integration/cluster/reattach and 1 other directories.

[do-not-reply at jboss.org]

Author: timfox
Date: 2009-12-02 16:57:11 -0500 (Wed, 02 Dec 2009)
New Revision: 8509

Removed:
   trunk/tests/src/org/hornetq/tests/util/sizeof/
Modified:
   trunk/src/main/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java
   trunk/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java
   trunk/src/main/org/hornetq/core/client/impl/DelegatingSession.java
   trunk/tests/src/org/hornetq/tests/integration/cluster/reattach/MultiThreadRandomReattachTestBase.java
Log:
removed unnecessary tests

Modified: trunk/src/main/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java	2009-12-02 20:51:57 UTC (rev 8508)
+++ trunk/src/main/org/hornetq/core/client/impl/ClientSessionFactoryImpl.java	2009-12-02 21:57:11 UTC (rev 8509)
@@ -1077,7 +1077,7 @@
       }
    }
 
-   private ClientSession createSessionInternal(final String username,
+   private synchronized ClientSession createSessionInternal(final String username,
                                                final String password,
                                                final boolean xa,
                                                final boolean autoCommitSends,

Modified: trunk/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java	2009-12-02 20:51:57 UTC (rev 8508)
+++ trunk/src/main/org/hornetq/core/client/impl/ClientSessionImpl.java	2009-12-02 21:57:11 UTC (rev 8509)
@@ -731,6 +731,7 @@
    {
       if (closed)
       {
+         log.info("Already closed so not closing");
          return;
       }
 

Modified: trunk/src/main/org/hornetq/core/client/impl/DelegatingSession.java
===================================================================
--- trunk/src/main/org/hornetq/core/client/impl/DelegatingSession.java	2009-12-02 20:51:57 UTC (rev 8508)
+++ trunk/src/main/org/hornetq/core/client/impl/DelegatingSession.java	2009-12-02 21:57:11 UTC (rev 8509)
@@ -72,7 +72,8 @@
    {
       if (!session.isClosed())
       {
-         log.warn("I'm closing a core ClientSession you left open. Please make sure you close all ClientSessions explicitly " + "before letting them go out of scope!");
+         log.warn("I'm closing a core ClientSession you left open. Please make sure you close all ClientSessions explicitly " + "before letting them go out of scope! " +
+                  System.identityHashCode(this));
 
          log.warn("The ClientSession you didn't close was created here:", creationStack);
 

Modified: trunk/tests/src/org/hornetq/tests/integration/cluster/reattach/MultiThreadRandomReattachTestBase.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/cluster/reattach/MultiThreadRandomReattachTestBase.java	2009-12-02 20:51:57 UTC (rev 8508)
+++ trunk/tests/src/org/hornetq/tests/integration/cluster/reattach/MultiThreadRandomReattachTestBase.java	2009-12-02 21:57:11 UTC (rev 8509)
@@ -1097,13 +1097,17 @@
     */
    protected void doTestL(final ClientSessionFactory sf) throws Exception
    {
-      final int numSessions = 10;
+      final int numSessions = 1000;
 
       for (int i = 0; i < numSessions; i++)
       {
          ClientSession session = sf.createSession(false, false, false);
+         
+         log.info("Created session " + System.identityHashCode(session));
 
          session.close();
+         
+         log.info("closed session");
       }
    }
 
@@ -1274,7 +1278,7 @@
 
    protected int getNumIterations()
    {
-      return 3;
+      return 1000;
    }
 
    @Override