activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject svn commit: r476058 - in /incubator/activemq/trunk/assembly/src/release/example/src: ConsumerTool.java RequesterTool.java
Date Fri, 17 Nov 2006 06:22:03 GMT
Author: jlim
Date: Thu Nov 16 22:22:02 2006
New Revision: 476058

URL: http://svn.apache.org/viewvc?view=rev&rev=476058
Log:
applied patches for http://issues.apache.org/activemq/browse/AMQ-1057

Modified:
    incubator/activemq/trunk/assembly/src/release/example/src/ConsumerTool.java
    incubator/activemq/trunk/assembly/src/release/example/src/RequesterTool.java

Modified: incubator/activemq/trunk/assembly/src/release/example/src/ConsumerTool.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/assembly/src/release/example/src/ConsumerTool.java?view=diff&rev=476058&r1=476057&r2=476058
==============================================================================
--- incubator/activemq/trunk/assembly/src/release/example/src/ConsumerTool.java (original)
+++ incubator/activemq/trunk/assembly/src/release/example/src/ConsumerTool.java Thu Nov 16
22:22:02 2006
@@ -90,7 +90,7 @@
 			connection.setExceptionListener(this);
 			connection.start();
 
-			Session session = connection.createSession(transacted, ackMode);
+			session = connection.createSession(transacted, ackMode);
 			if (topic) {
 				destination = session.createTopic(subject);
 			} else {

Modified: incubator/activemq/trunk/assembly/src/release/example/src/RequesterTool.java
URL: http://svn.apache.org/viewvc/incubator/activemq/trunk/assembly/src/release/example/src/RequesterTool.java?view=diff&rev=476058&r1=476057&r2=476058
==============================================================================
--- incubator/activemq/trunk/assembly/src/release/example/src/RequesterTool.java (original)
+++ incubator/activemq/trunk/assembly/src/release/example/src/RequesterTool.java Thu Nov 16
22:22:02 2006
@@ -93,13 +93,13 @@
 			// And the Destinations..
 			if (topic) {
 				destination = session.createTopic(subject);
-				if( replySubject==null )
+				if( replySubject==null || replySubject.equals("") )
 					replyDest = session.createTemporaryTopic();
 				else
 					replyDest = session.createTopic(replySubject);
 			} else {
 				destination = session.createQueue(subject);
-				if( replySubject==null )
+				if( replySubject==null || replySubject.equals("") )
 					replyDest = session.createTemporaryQueue();
 				else
 					replyDest = session.createQueue(replySubject);



Mime
View raw message