Simplifying with Rajith's help

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@935058 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 2 insertions, 9 deletions

diff --git a/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/hello/Hello.java b/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/hello/Hello.java
index 1cc46a8cef..ef8d4725fe 100644
--- a/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/hello/Hello.java
+++ b/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/hello/Hello.java
@@ -27,8 +27,6 @@ import java.util.Properties;
 
 
 public class Hello {
-    private static final String CLASS = "Hello";
-
 
     public Hello() {
     }
@@ -51,6 +49,7 @@ public class Hello {
                     e.printStackTrace();
                 }
             });
+            connection.start();
 
             Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
             Destination destination = (Destination) context.lookup("topicExchange");
@@ -62,18 +61,12 @@ public class Hello {
             messageProducer.send(message);
 
             message = messageConsumer.receive();
-            if (message instanceof TextMessage) {
-                String text = ((TextMessage) message).getText();
-                System.out.println(text);
-            } else {
-                System.out.println("Ooops, not a TextMessage!");
-            }
+            System.out.println(message.getText());
 
             connection.close();
             context.close();
         }
         catch (Exception exp) {
-            System.err.println(CLASS + ": Caught an Exception: " + exp);
             exp.printStackTrace();
         }
     }