svn commit: r476058 - in /incubator/activemq/trunk/assembly/src/release/example/src: ConsumerTool.java RequesterTool.java

[jlim]

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);