You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by lq...@apache.org on 2016/09/16 15:27:03 UTC
svn commit: r1761050 - in
/qpid/java/branches/6.0.x/client/example/src/main/java/org/apache/qpid/example:
Hello.java hello.properties
Author: lquack
Date: Fri Sep 16 15:27:03 2016
New Revision: 1761050
URL: http://svn.apache.org/viewvc?rev=1761050&view=rev
Log:
QPID-7382: [Java Broker, WMC] Revert unintended changes to client Hello World example
Modified:
qpid/java/branches/6.0.x/client/example/src/main/java/org/apache/qpid/example/Hello.java
qpid/java/branches/6.0.x/client/example/src/main/java/org/apache/qpid/example/hello.properties
Modified: qpid/java/branches/6.0.x/client/example/src/main/java/org/apache/qpid/example/Hello.java
URL: http://svn.apache.org/viewvc/qpid/java/branches/6.0.x/client/example/src/main/java/org/apache/qpid/example/Hello.java?rev=1761050&r1=1761049&r2=1761050&view=diff
==============================================================================
--- qpid/java/branches/6.0.x/client/example/src/main/java/org/apache/qpid/example/Hello.java (original)
+++ qpid/java/branches/6.0.x/client/example/src/main/java/org/apache/qpid/example/Hello.java Fri Sep 16 15:27:03 2016
@@ -27,7 +27,6 @@ import java.util.Properties;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
-import javax.jms.MapMessage;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Session;
@@ -62,7 +61,7 @@ public class Hello
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
- Destination destination = (Destination) context.lookup("myQueue");
+ Destination destination = (Destination) context.lookup("topicExchange");
MessageProducer messageProducer = session.createProducer(destination);
MessageConsumer messageConsumer = session.createConsumer(destination);
@@ -70,26 +69,6 @@ public class Hello
TextMessage message = session.createTextMessage("Hello world!");
messageProducer.send(message);
- MapMessage mm = session.createMapMessage();
- mm.setBoolean("b", true);
- mm.setString("s", "fnord");
- mm.setLong("l", 123456789123L);
- messageProducer.send(mm);
-
- TextMessage longMessage = session.createTextMessage("LongMessage\n"
- + "0123456789112345678921234567893123456789412345678951234567896123456789712345678981234567899123456789\n"
- + "0123456789112345678921234567893123456789412345678951234567896123456789712345678981234567899123456789\n"
- + "0123456789112345678921234567893123456789412345678951234567896123456789712345678981234567899123456789\n"
- + "0123456789112345678921234567893123456789412345678951234567896123456789712345678981234567899123456789\n"
- + "0123456789112345678921234567893123456789412345678951234567896123456789712345678981234567899123456789\n"
- + "0123456789112345678921234567893123456789412345678951234567896123456789712345678981234567899123456789\n"
- + "0123456789112345678921234567893123456789412345678951234567896123456789712345678981234567899123456789\n"
- + "0123456789112345678921234567893123456789412345678951234567896123456789712345678981234567899123456789\n"
- + "0123456789112345678921234567893123456789412345678951234567896123456789712345678981234567899123456789\n"
- + "0123456789112345678921234567893123456789412345678951234567896123456789712345678981234567899123456789\n"
- + "0123456789112345678921234567893123456789412345678951234567896123456789712345678981234567899123456789\n");
- messageProducer.send(longMessage);
-
message = (TextMessage)messageConsumer.receive();
System.out.println(message.getText());
Modified: qpid/java/branches/6.0.x/client/example/src/main/java/org/apache/qpid/example/hello.properties
URL: http://svn.apache.org/viewvc/qpid/java/branches/6.0.x/client/example/src/main/java/org/apache/qpid/example/hello.properties?rev=1761050&r1=1761049&r2=1761050&view=diff
==============================================================================
--- qpid/java/branches/6.0.x/client/example/src/main/java/org/apache/qpid/example/hello.properties (original)
+++ qpid/java/branches/6.0.x/client/example/src/main/java/org/apache/qpid/example/hello.properties Fri Sep 16 15:27:03 2016
@@ -25,4 +25,3 @@ connectionfactory.qpidConnectionfactory
# Register an AMQP destination in JNDI
# destination.[jniName] = [Address Format]
destination.topicExchange = amq.topic
-queue.myQueue = testQueue
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org