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