From c1d82a43c6b5edafd27afb751e07db1a0d6bc73c Mon Sep 17 00:00:00 2001 From: "Jonas B. Lim" Date: Fri, 17 Nov 2006 06:22:02 +0000 Subject: [PATCH] applied patches for http://issues.apache.org/activemq/browse/AMQ-1057 git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@476058 13f79535-47bb-0310-9956-ffa450edef68 --- assembly/src/release/example/src/ConsumerTool.java | 2 +- assembly/src/release/example/src/RequesterTool.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/assembly/src/release/example/src/ConsumerTool.java b/assembly/src/release/example/src/ConsumerTool.java index 427526c918..919a5ce19e 100755 --- a/assembly/src/release/example/src/ConsumerTool.java +++ b/assembly/src/release/example/src/ConsumerTool.java @@ -90,7 +90,7 @@ public class ConsumerTool implements MessageListener, ExceptionListener { connection.setExceptionListener(this); connection.start(); - Session session = connection.createSession(transacted, ackMode); + session = connection.createSession(transacted, ackMode); if (topic) { destination = session.createTopic(subject); } else { diff --git a/assembly/src/release/example/src/RequesterTool.java b/assembly/src/release/example/src/RequesterTool.java index cb2549f00d..5724959e8a 100644 --- a/assembly/src/release/example/src/RequesterTool.java +++ b/assembly/src/release/example/src/RequesterTool.java @@ -93,13 +93,13 @@ public class RequesterTool { // 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);