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-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org
