From db58758cc506b769f8c12f8b47608bf6550b5ca6 Mon Sep 17 00:00:00 2001 From: Jonathan Robie Date: Fri, 16 Apr 2010 19:37:31 +0000 Subject: Simplifying with Rajith's help git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@935058 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/qpid/example/jmsexample/hello/Hello.java | 11 ++--------- 1 file changed, 2 insertions(+), 9 deletions(-) (limited to 'java/client/example/src') 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(); } } -- cgit v1.2.1