From eb56a638b2aea7e56c55e49b267cfe2f673afe51 Mon Sep 17 00:00:00 2001 From: Rajith Muditha Attapattu Date: Fri, 16 Apr 2010 19:48:27 +0000 Subject: Fixed a minor compile issue and changed the prop file to denote the syntax as "addressing" instead of binding URL git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@935061 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/qpid/example/jmsexample/hello/Hello.java | 4 ++-- .../java/org/apache/qpid/example/jmsexample/hello/hello.properties | 2 +- 2 files changed, 3 insertions(+), 3 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 ef8d4725fe..3de1bd2a61 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 @@ -57,10 +57,10 @@ public class Hello { MessageProducer messageProducer = session.createProducer(destination); MessageConsumer messageConsumer = session.createConsumer(destination); - Message message = session.createTextMessage("Hello world!"); + TextMessage message = session.createTextMessage("Hello world!"); messageProducer.send(message); - message = messageConsumer.receive(); + message = (TextMessage)messageConsumer.receive(); System.out.println(message.getText()); connection.close(); diff --git a/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/hello/hello.properties b/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/hello/hello.properties index 839439ae4a..27ea66b318 100644 --- a/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/hello/hello.properties +++ b/java/client/example/src/main/java/org/apache/qpid/example/jmsexample/hello/hello.properties @@ -23,5 +23,5 @@ java.naming.factory.initial = org.apache.qpid.jndi.PropertiesFileInitialContextF connectionfactory.qpidConnectionfactory = amqp://guest:guest@clientid/test?brokerlist='tcp://localhost:5672' # Register an AMQP destination in JNDI -# destination.[jniName] = [BindingURL] +# destination.[jniName] = [Address Format] destination.topicExchange = amq.topic -- cgit v1.2.1