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