You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2006/11/17 15:08:38 UTC
svn commit: r476144 - in
/incubator/activemq/branches/activemq-4.1/assembly/src/release/example/src:
ConsumerTool.java RequesterTool.java
Author: chirino
Date: Fri Nov 17 06:08:36 2006
New Revision: 476144
URL: http://svn.apache.org/viewvc?view=rev&rev=476144
Log:
http://issues.apache.org/activemq/browse/AMQ-1057
Modified:
incubator/activemq/branches/activemq-4.1/assembly/src/release/example/src/ConsumerTool.java
incubator/activemq/branches/activemq-4.1/assembly/src/release/example/src/RequesterTool.java
Modified: incubator/activemq/branches/activemq-4.1/assembly/src/release/example/src/ConsumerTool.java
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.1/assembly/src/release/example/src/ConsumerTool.java?view=diff&rev=476144&r1=476143&r2=476144
==============================================================================
--- incubator/activemq/branches/activemq-4.1/assembly/src/release/example/src/ConsumerTool.java (original)
+++ incubator/activemq/branches/activemq-4.1/assembly/src/release/example/src/ConsumerTool.java Fri Nov 17 06:08:36 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/branches/activemq-4.1/assembly/src/release/example/src/RequesterTool.java
URL: http://svn.apache.org/viewvc/incubator/activemq/branches/activemq-4.1/assembly/src/release/example/src/RequesterTool.java?view=diff&rev=476144&r1=476143&r2=476144
==============================================================================
--- incubator/activemq/branches/activemq-4.1/assembly/src/release/example/src/RequesterTool.java (original)
+++ incubator/activemq/branches/activemq-4.1/assembly/src/release/example/src/RequesterTool.java Fri Nov 17 06:08:36 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);