Author: rajith
Date: Tue May 3 14:04:46 2011
New Revision: 1099060
URL: http://svn.apache.org/viewvc?rev=1099060&view=rev
Log:
QPID-3214
Committing the suggested fix by Gordon Sim.
All though the currentException may change by the time we call
connection.exceptionReceived() it's not really a big issue.
Chance of getting two successive sessions exceptions is rare if not none at all.
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java?rev=1099060&r1=1099059&r2=1099060&view=diff
==============================================================================
---
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
(original)
+++
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
Tue May 3 14:04:46 2011
@@ -1029,11 +1029,9 @@ public class AMQSession_0_10 extends AMQ
code = ee.getErrorCode().getValue();
}
AMQException amqe = new
AMQException(AMQConstant.getConstant(code), se.getMessage(), se.getCause());
-
- _connection.exceptionReceived(amqe);
-
_currentException = amqe;
}
+ _connection.exceptionReceived(_currentException);
}
public AMQMessageDelegateFactory getMessageDelegateFactory()
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
