Author: jstrachan
Date: Thu Jan 5 06:48:09 2006
New Revision: 366188
URL: http://svn.apache.org/viewcvs?rev=366188&view=rev
Log:
fixed reconnection test which was creating a new connection with a client ID
before closing the previous one which threw the InvalidClientIDException
Modified:
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java
Modified:
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java
URL:
http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java?rev=366188&r1=366187&r2=366188&view=diff
==============================================================================
---
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java
(original)
+++
incubator/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/JmsTransactionTestSupport.java
Thu Jan 5 06:48:09 2006
@@ -426,12 +426,11 @@
*/
protected void reconnect() throws JMSException {
- Connection t = resourceProvider.createConnection(connectionFactory);
if (connection != null) {
// Close the previous connection.
connection.close();
}
- connection = t;
+ connection = resourceProvider.createConnection(connectionFactory);
session = resourceProvider.createSession(connection);
destination = resourceProvider.createDestination(session,
getSubject());