diff options
| -rw-r--r-- | java/client/example/src/main/java/org/apache/qpid/example/jmsexample/hello/Hello.java | 4 | ||||
| -rw-r--r-- | java/client/example/src/main/java/org/apache/qpid/example/jmsexample/hello/hello.properties | 2 |
2 files changed, 3 insertions, 3 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 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 |