[jboss-cvs] JBossAS SVN: r61741 - trunk/jbossmq/src/main/org/jboss/mq.

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

Author: adrian at jboss.org
Date: 2007-03-27 11:36:55 -0400 (Tue, 27 Mar 2007)
New Revision: 61741

Modified:
   trunk/jbossmq/src/main/org/jboss/mq/Connection.java
Log:
[JBAS-4256] - Trigger the exception listener when the client does not initiate the close request

Modified: trunk/jbossmq/src/main/org/jboss/mq/Connection.java
===================================================================
--- trunk/jbossmq/src/main/org/jboss/mq/Connection.java	2007-03-27 15:36:25 UTC (rev 61740)
+++ trunk/jbossmq/src/main/org/jboss/mq/Connection.java	2007-03-27 15:36:55 UTC (rev 61741)
@@ -338,7 +338,9 @@
 	 */
    public void asynchClose()
    {
-      // This obviously did something at some point?
+      // If we receive a close and we did not initiate it, then fire the exception listener
+      if (closing.get() == false)
+         asynchFailure("Asynchronous close from server.", new IOException("Close request from the server or transport layer."));
    }
 
    /**