You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by jl...@apache.org on 2006/11/17 07:22:03 UTC
svn commit: r476058 - in
/incubator/activemq/trunk/assembly/src/release/example/src:
ConsumerTool.java RequesterTool.java
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);