[jboss-cvs] JBoss Messaging SVN: r7739 - in trunk/src/main/org/jboss/messaging: jms/client and 1 other directory.

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

Author: timfox
Date: 2009-08-15 15:16:23 -0400 (Sat, 15 Aug 2009)
New Revision: 7739

Modified:
   trunk/src/main/org/jboss/messaging/core/client/impl/DelegatingSession.java
   trunk/src/main/org/jboss/messaging/jms/client/JBossConnection.java
Log:
added some more diagnostics

Modified: trunk/src/main/org/jboss/messaging/core/client/impl/DelegatingSession.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/impl/DelegatingSession.java	2009-08-15 18:21:43 UTC (rev 7738)
+++ trunk/src/main/org/jboss/messaging/core/client/impl/DelegatingSession.java	2009-08-15 19:16:23 UTC (rev 7739)
@@ -58,6 +58,8 @@
    
    private final ClientSessionInternal session;
    
+   private Exception creationStack;
+   
    @Override
    protected void finalize() throws Throwable
    {
@@ -65,6 +67,8 @@
       {
          log.warn("I'm closing a ClientSession you left open. Please make sure you close all ClientSessions explicitly " + "before letting them go out of scope!");
          
+         log.warn("The session you didn't close was created here:", creationStack);
+         
          close();
       }
 
@@ -75,6 +79,8 @@
    public DelegatingSession(final ClientSessionInternal session)
    {
       this.session = session;
+      
+      this.creationStack = new Exception();
    }
 
    public void acknowledge(long consumerID, long messageID) throws MessagingException

Modified: trunk/src/main/org/jboss/messaging/jms/client/JBossConnection.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/client/JBossConnection.java	2009-08-15 18:21:43 UTC (rev 7738)
+++ trunk/src/main/org/jboss/messaging/jms/client/JBossConnection.java	2009-08-15 19:16:23 UTC (rev 7739)
@@ -113,7 +113,7 @@
 
    private final String password;
 
-   private final FailureListener listener = new JMSFailureListener();
+   private final FailureListener listener = new JMSFailureListener(this);
 
    private final Version thisVersion;
 
@@ -535,6 +535,11 @@
    {
       private WeakReference<JBossConnection> connectionRef;
       
+      JMSFailureListener(final JBossConnection connection)
+      {
+         connectionRef = new WeakReference<JBossConnection>(connection);
+      }
+      
       public synchronized void connectionFailed(final MessagingException me)
       {
          if (me == null)