You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2017/11/21 22:35:40 UTC
[23/23] qpid-site git commit: NO-JIRA: Update site for Qpid JMS AMQP
0-x release 6.3.0
NO-JIRA: Update site for Qpid JMS AMQP 0-x release 6.3.0
Project: http://git-wip-us.apache.org/repos/asf/qpid-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-site/commit/1c801de7
Tree: http://git-wip-us.apache.org/repos/asf/qpid-site/tree/1c801de7
Diff: http://git-wip-us.apache.org/repos/asf/qpid-site/diff/1c801de7
Branch: refs/heads/asf-site
Commit: 1c801de73ef00811a48debf00c284ecee6c8d7b4
Parents: fd5570e
Author: Alex Rudyy <or...@apache.org>
Authored: Tue Nov 21 22:34:44 2017 +0000
Committer: Alex Rudyy <or...@apache.org>
Committed: Tue Nov 21 22:34:44 2017 +0000
----------------------------------------------------------------------
content/components/jms/amqp-0-x.html | 24 +-
content/maven.html | 2 +-
content/releases/index.html | 1 +
.../qpid-jms-amqp-0-x-6.3.0/examples/Drain.java | 103 +++
.../examples/Drain.java.html | 232 ++++++
.../qpid-jms-amqp-0-x-6.3.0/examples/Hello.java | 83 +++
.../examples/Hello.java.html | 211 ++++++
.../examples/ListReceiver.java | 101 +++
.../examples/ListReceiver.java.html | 229 ++++++
.../examples/ListSender.java | 86 +++
.../examples/ListSender.java.html | 214 ++++++
.../examples/MapReceiver.java | 52 ++
.../examples/MapReceiver.java.html | 180 +++++
.../examples/MapSender.java | 83 +++
.../examples/MapSender.java.html | 211 ++++++
.../examples/OptionParser.java | 351 +++++++++
.../examples/OptionParser.java.html | 480 ++++++++++++
.../qpid-jms-amqp-0-x-6.3.0/examples/Spout.java | 149 ++++
.../examples/Spout.java.html | 278 +++++++
.../examples/hello.properties | 28 +
.../examples/hello.properties.html | 158 ++++
.../qpid-jms-amqp-0-x-6.3.0/examples/index.html | 166 +++++
.../releases/qpid-jms-amqp-0-x-6.3.0/index.html | 215 ++++++
.../JMS-Client-0-10-Book.html | 144 ++++
.../JMS-Client-0-10-Configuring-Addresses.html | 727 +++++++++++++++++++
.../JMS-Client-0-10-Configuring-JNDI.html | 432 +++++++++++
...-Client-0-10-Configuring-JVM-Properties.html | 186 +++++
.../JMS-Client-0-10-Configuring-Logging.html | 152 ++++
.../JMS-Client-0-10-Configuring.html | 154 ++++
.../JMS-Client-0-10-Example.html | 221 ++++++
...S-Client-0-10-Miscellaneous-MapMessages.html | 191 +++++
.../JMS-Client-0-10-Miscellaneous.html | 151 ++++
.../jms-amqp-0-10-book/css/style.css | 131 ++++
.../jms-amqp-0-10-book/index.html | 144 ++++
.../JMS-Client-0-8-Appendix-Exceptions.html | 197 +++++
...ent-0-8-Appendix-JMS-Extensions-Binding.html | 163 +++++
.../JMS-Client-0-8-Appendix-JMS-Extensions.html | 158 ++++
.../JMS-Client-0-8-Appendix-Maven.html | 175 +++++
...t-0-8-Appendix-PooledConnecytionFactory.html | 195 +++++
...0-8-Appendix-ProducerFlowControl-Impact.html | 183 +++++
...nt-0-8-Appendix-Tomcat-JNDI-Integration.html | 266 +++++++
.../JMS-Client-0-8-Binding-URL.html | 222 ++++++
...ent-0-8-Client-Understanding-Connection.html | 215 ++++++
...-Client-Understanding-ConnectionFactory.html | 151 ++++
...t-0-8-Client-Understanding-Destinations.html | 149 ++++
...-8-Client-Understanding-MessageConsumer.html | 171 +++++
...-8-Client-Understanding-MessageProducer.html | 190 +++++
...Client-0-8-Client-Understanding-Session.html | 208 ++++++
.../JMS-Client-0-8-Client-Understanding.html | 150 ++++
.../JMS-Client-0-8-Connection-URL.html | 269 +++++++
...-8-Document-Scope-And-Intended-Audience.html | 161 ++++
.../JMS-Client-0-8-Examples-PubSub.html | 216 ++++++
.../JMS-Client-0-8-Examples.html | 218 ++++++
.../JMS-Client-0-8-Introduction.html | 153 ++++
...S-Getting-And-Dependencies-Dependencies.html | 148 ++++
...Client-0-8-JMS-Getting-And-Dependencies.html | 154 ++++
...-0-8-JNDI-Properties-Format-Destination.html | 146 ++++
...Client-0-8-JNDI-Properties-Format-Queue.html | 145 ++++
...Client-0-8-JNDI-Properties-Format-Topic.html | 147 ++++
.../JMS-Client-0-8-JNDI-Properties-Format.html | 157 ++++
...Client-0-8-Logging-EnablingDebugLogging.html | 151 ++++
.../JMS-Client-0-8-Logging.html | 155 ++++
.../JMS-Client-0-8-System-Properties.html | 280 +++++++
.../jms-amqp-0-8-book/JMS-Client-Book.html | 150 ++++
.../JMS-Client-Message-Encryption-Example.html | 326 +++++++++
...JMS-Client-Message-Encryption-Receiving.html | 154 ++++
.../JMS-Client-Message-Encryption-Sending.html | 203 ++++++
.../JMS-Client-Message-Encryption.html | 177 +++++
.../jms-amqp-0-8-book/css/style.css | 131 ++++
.../jms-amqp-0-8-book/images/JndiOverview.png | Bin 0 -> 67726 bytes
.../jms-amqp-0-8-book/images/JndiOverview.svg | 23 +
.../images/QpidJmsOverview.png | Bin 0 -> 52377 bytes
.../images/QpidJmsOverview.svg | 23 +
.../jms-amqp-0-8-book/index.html | 150 ++++
.../qpid-jms-amqp-0-x-6.3.0/release-notes.html | 199 +++++
.../qpid-jms-amqp-0-x-6.3.0/examples/Drain.java | 103 +++
.../examples/Drain.java.html.in | 88 +++
.../qpid-jms-amqp-0-x-6.3.0/examples/Hello.java | 83 +++
.../examples/Hello.java.html.in | 67 ++
.../examples/ListReceiver.java | 101 +++
.../examples/ListReceiver.java.html.in | 85 +++
.../examples/ListSender.java | 86 +++
.../examples/ListSender.java.html.in | 70 ++
.../examples/MapReceiver.java | 52 ++
.../examples/MapReceiver.java.html.in | 36 +
.../examples/MapSender.java | 83 +++
.../examples/MapSender.java.html.in | 67 ++
.../examples/OptionParser.java | 351 +++++++++
.../examples/OptionParser.java.html.in | 336 +++++++++
.../qpid-jms-amqp-0-x-6.3.0/examples/Spout.java | 149 ++++
.../examples/Spout.java.html.in | 134 ++++
.../examples/hello.properties | 28 +
.../examples/hello.properties.html.in | 14 +
.../qpid-jms-amqp-0-x-6.3.0/examples/index.md | 19 +
input/releases/qpid-jms-amqp-0-x-6.3.0/index.md | 69 ++
.../JMS-Client-0-10-Book.html.in | 1 +
...MS-Client-0-10-Configuring-Addresses.html.in | 584 +++++++++++++++
.../JMS-Client-0-10-Configuring-JNDI.html.in | 289 ++++++++
...ient-0-10-Configuring-JVM-Properties.html.in | 43 ++
.../JMS-Client-0-10-Configuring-Logging.html.in | 9 +
.../JMS-Client-0-10-Configuring.html.in | 11 +
.../JMS-Client-0-10-Example.html.in | 78 ++
...lient-0-10-Miscellaneous-MapMessages.html.in | 48 ++
.../JMS-Client-0-10-Miscellaneous.html.in | 8 +
.../jms-amqp-0-10-book/css/style.css | 131 ++++
.../jms-amqp-0-10-book/index.html.in | 1 +
.../JMS-Client-0-8-Appendix-Exceptions.html.in | 54 ++
...-0-8-Appendix-JMS-Extensions-Binding.html.in | 20 +
...S-Client-0-8-Appendix-JMS-Extensions.html.in | 15 +
.../JMS-Client-0-8-Appendix-Maven.html.in | 32 +
...-8-Appendix-PooledConnecytionFactory.html.in | 52 ++
...-Appendix-ProducerFlowControl-Impact.html.in | 40 +
...0-8-Appendix-Tomcat-JNDI-Integration.html.in | 123 ++++
.../JMS-Client-0-8-Binding-URL.html.in | 79 ++
...-0-8-Client-Understanding-Connection.html.in | 72 ++
...ient-Understanding-ConnectionFactory.html.in | 8 +
...-8-Client-Understanding-Destinations.html.in | 6 +
...Client-Understanding-MessageConsumer.html.in | 28 +
...Client-Understanding-MessageProducer.html.in | 47 ++
...ent-0-8-Client-Understanding-Session.html.in | 65 ++
.../JMS-Client-0-8-Client-Understanding.html.in | 7 +
.../JMS-Client-0-8-Connection-URL.html.in | 126 ++++
...Document-Scope-And-Intended-Audience.html.in | 18 +
.../JMS-Client-0-8-Examples-PubSub.html.in | 73 ++
.../JMS-Client-0-8-Examples.html.in | 75 ++
.../JMS-Client-0-8-Introduction.html.in | 10 +
...etting-And-Dependencies-Dependencies.html.in | 5 +
...ent-0-8-JMS-Getting-And-Dependencies.html.in | 11 +
...8-JNDI-Properties-Format-Destination.html.in | 3 +
...ent-0-8-JNDI-Properties-Format-Queue.html.in | 2 +
...ent-0-8-JNDI-Properties-Format-Topic.html.in | 4 +
...MS-Client-0-8-JNDI-Properties-Format.html.in | 14 +
...ent-0-8-Logging-EnablingDebugLogging.html.in | 8 +
.../JMS-Client-0-8-Logging.html.in | 12 +
.../JMS-Client-0-8-System-Properties.html.in | 137 ++++
.../jms-amqp-0-8-book/JMS-Client-Book.html.in | 7 +
...MS-Client-Message-Encryption-Example.html.in | 183 +++++
...-Client-Message-Encryption-Receiving.html.in | 11 +
...MS-Client-Message-Encryption-Sending.html.in | 60 ++
.../JMS-Client-Message-Encryption.html.in | 34 +
.../jms-amqp-0-8-book/css/style.css | 131 ++++
.../jms-amqp-0-8-book/images/JndiOverview.png | Bin 0 -> 67726 bytes
.../jms-amqp-0-8-book/images/JndiOverview.svg | 23 +
.../images/QpidJmsOverview.png | Bin 0 -> 52377 bytes
.../images/QpidJmsOverview.svg | 23 +
.../jms-amqp-0-8-book/index.html.in | 7 +
.../qpid-jms-amqp-0-x-6.3.0/release-notes.md | 71 ++
147 files changed, 18005 insertions(+), 14 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/1c801de7/content/components/jms/amqp-0-x.html
----------------------------------------------------------------------
diff --git a/content/components/jms/amqp-0-x.html b/content/components/jms/amqp-0-x.html
index a95d7e0..1a971cd 100644
--- a/content/components/jms/amqp-0-x.html
+++ b/content/components/jms/amqp-0-x.html
@@ -21,7 +21,7 @@
-->
<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en">
<head>
- <title>AMQP 0-x JMS - Apache Qpid™</title>
+ <title>Qpid JMS AMQP 0-x - Apache Qpid™</title>
<meta http-equiv="X-UA-Compatible" content="IE=edge"/>
<meta name="viewport" content="width=device-width, initial-scale=1.0"/>
<link rel="stylesheet" href="/site.css" type="text/css" async="async"/>
@@ -111,25 +111,23 @@ https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
</div>
<div id="-middle" class="panel">
- <ul id="-path-navigation"><li><a href="/index.html">Home</a></li><li><a href="/components/index.html">Components</a></li><li><a href="/components/jms/index.html">Qpid JMS</a></li><li>AMQP 0-x JMS</li></ul>
+ <ul id="-path-navigation"><li><a href="/index.html">Home</a></li><li><a href="/components/index.html">Components</a></li><li><a href="/components/jms/index.html">Qpid JMS</a></li><li>Qpid JMS AMQP 0-x</li></ul>
<div id="-middle-content">
- <h1 id="amqp-0-x-jms">AMQP 0-x JMS</h1>
+ <h1 id="qpid-jms-amqp-0-x">Qpid JMS AMQP 0-x</h1>
<p>A JMS 1.1 implementation supporting AMQP versions 0-10, 0-9-1, 0-9, and
0-8. For AMQP 1.0 support, use the newer <a href="index.html">Qpid JMS</a> client.</p>
<h2 id="download">Download</h2>
-<p>This JMS implementation is released as part of <a href="/releases/qpid-java-6.1.4">Qpid for Java 6.1.4</a>.</p>
-
<div class="two-column">
<ul>
-<li><a href="http://www.apache.org/dyn/closer.lua/qpid/java/6.1.4/binaries/qpid-client-6.1.4-bin.tar.gz">Java binary</a></li>
-<li><a href="http://www.apache.org/dist/qpid/java/6.1.4/binaries/qpid-client-6.1.4-bin.tar.gz.asc">PGP signature</a></li>
-<li><a href="http://www.apache.org/dist/qpid/java/6.1.4/binaries/qpid-client-6.1.4-bin.tar.gz.md5">MD5 checksum</a></li>
-<li><a href="http://www.apache.org/dist/qpid/java/6.1.4/binaries/qpid-client-6.1.4-bin.tar.gz.sha">SHA512 checksum</a></li>
+<li><a href="http://www.apache.org/dyn/closer.lua/qpid/jms-amqp-0-x/6.3.0/binaries/apache-qpid-jms-amqp-0-x-6.3.0-bin.tar.gz">Binary</a></li>
+<li><a href="http://www.apache.org/dist/qpid/jms-amqp-0-x/6.3.0/binaries/apache-qpid-jms-amqp-0-x-6.3.0-bin.tar.gz.asc">PGP signature</a></li>
+<li><a href="http://www.apache.org/dist/qpid/jms-amqp-0-x/6.3.0/binaries/apache-qpid-jms-amqp-0-x-6.3.0-bin.tar.gz.md5">MD5 checksum</a></li>
+<li><a href="http://www.apache.org/dist/qpid/jms-amqp-0-x/6.3.0/binaries/apache-qpid-jms-amqp-0-x-6.3.0-bin.tar.gz.sha512">SHA512 checksum</a></li>
</ul>
</div>
@@ -142,10 +140,10 @@ https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
<ul>
<li><a href="http://docs.oracle.com/javaee/1.4/api/javax/jms/package-summary.html">API reference</a></li>
-<li><a href="/releases/qpid-java-6.1.4/jms-client-0-10/book/index.html">Using the Qpid JMS client (AMQP 0-10)</a></li>
-<li><a href="/releases/qpid-java-6.1.4/jms-client-0-8/book/index.html">Using the Qpid JMS client (AMQP 0-9-1, 0-9, 0-8)</a></li>
-<li><a href="/releases/qpid-java-6.1.4/qpid-jms/examples/index.html">Examples (AMQP 0-10)</a></li>
-<li><a href="/releases/qpid-java-6.1.4/jms-client-0-8/book/JMS-Client-0-8-Examples.html">Examples (AMQP 0-9-1, 0-9, 0-8)</a></li>
+<li><a href="/releases/qpid-jms-amqp-0-x-6.3.0/jms-amqp-0-10-book/index.html">Using the Qpid JMS AMQP 0-x - AMQP 0-10</a></li>
+<li><a href="/releases/qpid-jms-amqp-0-x-6.3.0/jms-amqp-0-8-book/index.html">Using the Qpid JMS AMQP 0-x - AMQP 0-9-1, 0-9, 0-8</a></li>
+<li><a href="/releases/qpid-jms-amqp-0-x-6.3.0/examples/index.html">Examples (AMQP 0-10)</a></li>
+<li><a href="/releases/qpid-jms-amqp-0-x-6.3.0/jms-amqp-0-8-book/JMS-Client-0-8-Examples.html">Examples (AMQP 0-9-1, 0-9, 0-8)</a></li>
</ul>
</div>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/1c801de7/content/maven.html
----------------------------------------------------------------------
diff --git a/content/maven.html b/content/maven.html
index ef543d8..39378bf 100644
--- a/content/maven.html
+++ b/content/maven.html
@@ -134,7 +134,7 @@ https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.qpid<span class="nt"></groupId></span>
<span class="nt"><artifactId></span>qpid-client<span class="nt"></artifactId></span>
- <span class="nt"><version></span>6.1.4<span class="nt"></version></span>
+ <span class="nt"><version></span>6.3.0<span class="nt"></version></span>
<span class="nt"></dependency></span>
<span class="nt"><dependency></span>
<span class="nt"><groupId></span>org.apache.geronimo.specs<span class="nt"></groupId></span>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/1c801de7/content/releases/index.html
----------------------------------------------------------------------
diff --git a/content/releases/index.html b/content/releases/index.html
index debd029..a5ebe02 100644
--- a/content/releases/index.html
+++ b/content/releases/index.html
@@ -126,6 +126,7 @@ the
<div class="two-column">
<ul>
+<li><a href="qpid-jms-amqp-0-x-6.3.0/index.html">Qpid JMS AMQP 0-x 6.3.0</a>, November 2017</li>
<li><a href="qpid-broker-j-7.0.0/index.html">Qpid Broker-J 7.0.0</a>, November 2017</li>
<li><a href="qpid-jms-0.27.0/index.html">Qpid JMS 0.27.0</a>, October 2017</li>
<li><a href="qpid-proton-0.18.1/index.html">Qpid Proton 0.18.1</a>, November 2017</li>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/1c801de7/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/Drain.java
----------------------------------------------------------------------
diff --git a/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/Drain.java b/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/Drain.java
new file mode 100755
index 0000000..f0eb83a
--- /dev/null
+++ b/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/Drain.java
@@ -0,0 +1,103 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+package org.apache.qpid.example;
+
+import javax.jms.Connection;
+import javax.jms.Destination;
+import javax.jms.Message;
+import javax.jms.MessageConsumer;
+import javax.jms.Session;
+
+import org.apache.qpid.client.AMQAnyDestination;
+
+public class Drain extends OptionParser
+{
+
+ static final Option FOREVER = new Option("f",
+ "forever",
+ "ignore timeout and wait forever",
+ null,
+ null,
+ Boolean.class);
+
+ static final Option COUNT = new Option ("c",
+ "count",
+ "read c messages, then exit",
+ "COUNT",
+ "0",
+ Integer.class);
+
+
+ static
+ {
+ addOption(BROKER);
+ addOption(HELP);
+ addOption(TIMEOUT);
+ addOption(FOREVER);
+ addOption(COUNT);
+ addOption(CON_OPTIONS);
+ addOption(BROKER_OPTIONS);
+ }
+
+ public Drain(String[] args, String usage, String desc) throws Exception
+ {
+ super(args, usage, desc);
+
+ Connection con = createConnection();
+ con.start();
+ Session ssn = con.createSession(false,Session.AUTO_ACKNOWLEDGE);
+ Destination dest = new AMQAnyDestination(getAddress());
+ MessageConsumer consumer = ssn.createConsumer(dest);
+ Message msg;
+
+ long timeout = -1;
+ int count = 0;
+ int i = 0;
+
+ if (containsOp(TIMEOUT)) { timeout = Integer.parseInt(getOp(TIMEOUT))*1000; }
+ if (containsOp(FOREVER)) { timeout = 0; }
+ if (containsOp(COUNT)) { count = Integer.parseInt(getOp(COUNT)); }
+
+ while ((msg = consumer.receive(timeout)) != null)
+ {
+ System.out.println("\n------------- Msg -------------");
+ System.out.println(msg);
+ System.out.println("-------------------------------\n");
+
+ if (count > 0) {
+ if (++i == count) {
+ break;
+ }
+ }
+ }
+ consumer.close();
+ ssn.close();
+ con.close();
+ }
+
+ public static void main(String[] args) throws Exception
+ {
+ String u = "Usage: drain [OPTIONS] 'ADDRESS'";
+ String d = "Drains messages from the specified address.";
+
+ new Drain(args,u,d);
+ }
+}
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/1c801de7/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/Drain.java.html
----------------------------------------------------------------------
diff --git a/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/Drain.java.html b/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/Drain.java.html
new file mode 100644
index 0000000..f94f105
--- /dev/null
+++ b/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/Drain.java.html
@@ -0,0 +1,232 @@
+<!DOCTYPE html>
+<!--
+ -
+ - Licensed to the Apache Software Foundation (ASF) under one
+ - or more contributor license agreements. See the NOTICE file
+ - distributed with this work for additional information
+ - regarding copyright ownership. The ASF licenses this file
+ - to you under the Apache License, Version 2.0 (the
+ - "License"); you may not use this file except in compliance
+ - with the License. You may obtain a copy of the License at
+ -
+ - http://www.apache.org/licenses/LICENSE-2.0
+ -
+ - Unless required by applicable law or agreed to in writing,
+ - software distributed under the License is distributed on an
+ - "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ - KIND, either express or implied. See the License for the
+ - specific language governing permissions and limitations
+ - under the License.
+ -
+-->
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en">
+ <head>
+ <title>Drain.java - Apache Qpid™</title>
+ <meta http-equiv="X-UA-Compatible" content="IE=edge"/>
+ <meta name="viewport" content="width=device-width, initial-scale=1.0"/>
+ <link rel="stylesheet" href="/site.css" type="text/css" async="async"/>
+ <link rel="stylesheet" href="/deferred.css" type="text/css" defer="defer"/>
+ <script type="text/javascript">var _deferredFunctions = [];</script>
+ <script type="text/javascript" src="/deferred.js" defer="defer"></script>
+ <!--[if lte IE 8]>
+ <link rel="stylesheet" href="/ie.css" type="text/css"/>
+ <script type="text/javascript" src="/html5shiv.js"></script>
+ <![endif]-->
+
+ <!-- Redirects for `go get` and godoc.org -->
+ <meta name="go-import"
+ content="qpid.apache.org git https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+ <meta name="go-source"
+ content="qpid.apache.org
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+ </head>
+ <body>
+ <div id="-content">
+ <div id="-top" class="panel">
+ <a id="-menu-link"><img width="16" height="16" src="" alt="Menu"/></a>
+
+ <a id="-search-link"><img width="22" height="16" src="" alt="Search"/></a>
+
+ <ul id="-global-navigation">
+ <li><a id="-logotype" href="/index.html">Apache Qpid<sup>™</sup></a></li>
+ <li><a href="/documentation.html">Documentation</a></li>
+ <li><a href="/download.html">Download</a></li>
+ <li><a href="/discussion.html">Discussion</a></li>
+ </ul>
+ </div>
+
+ <div id="-menu" class="panel" style="display: none;">
+ <div class="flex">
+ <section>
+ <h3>Project</h3>
+
+ <ul>
+ <li><a href="/overview.html">Overview</a></li>
+ <li><a href="/components/index.html">Components</a></li>
+ <li><a href="/releases/index.html">Releases</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Messaging APIs</h3>
+
+ <ul>
+ <li><a href="/proton/index.html">Qpid Proton</a></li>
+ <li><a href="/components/jms/index.html">Qpid JMS</a></li>
+ <li><a href="/components/messaging-api/index.html">Qpid Messaging API</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Servers and tools</h3>
+
+ <ul>
+ <li><a href="/components/broker-j/index.html">Broker-J</a></li>
+ <li><a href="/components/cpp-broker/index.html">C++ broker</a></li>
+ <li><a href="/components/dispatch-router/index.html">Dispatch router</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Resources</h3>
+
+ <ul>
+ <li><a href="/dashboard.html">Dashboard</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/qpid/Index">Wiki</a></li>
+ <li><a href="/resources.html">More resources</a></li>
+ </ul>
+ </section>
+ </div>
+ </div>
+
+ <div id="-search" class="panel" style="display: none;">
+ <form action="http://www.google.com/search" method="get">
+ <input type="hidden" name="sitesearch" value="qpid.apache.org"/>
+ <input type="text" name="q" maxlength="255" autofocus="autofocus" tabindex="1"/>
+ <button type="submit">Search</button>
+ <a href="/search.html">More ways to search</a>
+ </form>
+ </div>
+
+ <div id="-middle" class="panel">
+ <ul id="-path-navigation"><li><a href="/index.html">Home</a></li><li><a href="/releases/index.html">Releases</a></li><li><a href="/releases/qpid-jms-amqp-0-x-6.3.0/index.html">Qpid JMS AMQP 0-x 6.3.0</a></li><li><a href="/releases/qpid-jms-amqp-0-x-6.3.0/examples/index.html">Qpid JMS AMQP 0-x Examples</a></li><li>Drain.java</li></ul>
+
+ <div id="-middle-content">
+
+<h1>Drain.java</h1>
+<div class="highlight"><pre><span></span><span class="kn">package</span> <span class="nn">org.apache.qpid.example</span><span class="o">;</span>
+
+<span class="kn">import</span> <span class="nn">javax.jms.Connection</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.jms.Destination</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.jms.Message</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.jms.MessageConsumer</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.jms.Session</span><span class="o">;</span>
+
+<span class="kn">import</span> <span class="nn">org.apache.qpid.client.AMQAnyDestination</span><span class="o">;</span>
+
+<span class="kd">public</span> <span class="kd">class</span> <span class="nc">Drain</span> <span class="kd">extends</span> <span class="n">OptionParser</span>
+<span class="o">{</span>
+
+ <span class="kd">static</span> <span class="kd">final</span> <span class="n">Option</span> <span class="n">FOREVER</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Option</span><span class="o">(</span><span class="s">"f"</span><span class="o">,</span>
+ <span class="s">"forever"</span><span class="o">,</span>
+ <span class="s">"ignore timeout and wait forever"</span><span class="o">,</span>
+ <span class="kc">null</span><span class="o">,</span>
+ <span class="kc">null</span><span class="o">,</span>
+ <span class="n">Boolean</span><span class="o">.</span><span class="na">class</span><span class="o">);</span>
+
+ <span class="kd">static</span> <span class="kd">final</span> <span class="n">Option</span> <span class="n">COUNT</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Option</span> <span class="o">(</span><span class="s">"c"</span><span class="o">,</span>
+ <span class="s">"count"</span><span class="o">,</span>
+ <span class="s">"read c messages, then exit"</span><span class="o">,</span>
+ <span class="s">"COUNT"</span><span class="o">,</span>
+ <span class="s">"0"</span><span class="o">,</span>
+ <span class="n">Integer</span><span class="o">.</span><span class="na">class</span><span class="o">);</span>
+
+
+ <span class="kd">static</span>
+ <span class="o">{</span>
+ <span class="n">addOption</span><span class="o">(</span><span class="n">BROKER</span><span class="o">);</span>
+ <span class="n">addOption</span><span class="o">(</span><span class="n">HELP</span><span class="o">);</span>
+ <span class="n">addOption</span><span class="o">(</span><span class="n">TIMEOUT</span><span class="o">);</span>
+ <span class="n">addOption</span><span class="o">(</span><span class="n">FOREVER</span><span class="o">);</span>
+ <span class="n">addOption</span><span class="o">(</span><span class="n">COUNT</span><span class="o">);</span>
+ <span class="n">addOption</span><span class="o">(</span><span class="n">CON_OPTIONS</span><span class="o">);</span>
+ <span class="n">addOption</span><span class="o">(</span><span class="n">BROKER_OPTIONS</span><span class="o">);</span>
+ <span class="o">}</span>
+
+ <span class="kd">public</span> <span class="nf">Drain</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">,</span> <span class="n">String</span> <span class="n">usage</span><span class="o">,</span> <span class="n">String</span> <span class="n">desc</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span>
+ <span class="o">{</span>
+ <span class="kd">super</span><span class="o">(</span><span class="n">args</span><span class="o">,</span> <span class="n">usage</span><span class="o">,</span> <span class="n">desc</span><span class="o">);</span>
+
+ <span class="n">Connection</span> <span class="n">con</span> <span class="o">=</span> <span class="n">createConnection</span><span class="o">();</span>
+ <span class="n">con</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>
+ <span class="n">Session</span> <span class="n">ssn</span> <span class="o">=</span> <span class="n">con</span><span class="o">.</span><span class="na">createSession</span><span class="o">(</span><span class="kc">false</span><span class="o">,</span><span class="n">Session</span><span class="o">.</span><span class="na">AUTO_ACKNOWLEDGE</span><span class="o">);</span>
+ <span class="n">Destination</span> <span class="n">dest</span> <span class="o">=</span> <span class="k">new</span> <span class="n">AMQAnyDestination</span><span class="o">(</span><span class="n">getAddress</span><span class="o">());</span>
+ <span class="n">MessageConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="n">ssn</span><span class="o">.</span><span class="na">createConsumer</span><span class="o">(</span><span class="n">dest</span><span class="o">);</span>
+ <span class="n">Message</span> <span class="n">msg</span><span class="o">;</span>
+
+ <span class="kt">long</span> <span class="n">timeout</span> <span class="o">=</span> <span class="o">-</span><span class="mi">1</span><span class="o">;</span>
+ <span class="kt">int</span> <span class="n">count</span> <span class="o">=</span> <span class="mi">0</span><span class="o">;</span>
+ <span class="kt">int</span> <span class="n">i</span> <span class="o">=</span> <span class="mi">0</span><span class="o">;</span>
+
+ <span class="k">if</span> <span class="o">(</span><span class="n">containsOp</span><span class="o">(</span><span class="n">TIMEOUT</span><span class="o">))</span> <span class="o">{</span> <span class="n">timeout</span> <span class="o">=</span> <span class="n">Integer</span><span class="o">.</span><span class="na">parseInt</span><span class="o">(</span><span class="n">getOp</span><span class="o">(</span><span class="n">TIMEOUT</span><span class="o">))*</span><span class="mi">1000</span><span class="o">;</span> <span class="o">}</span>
+ <span class="k">if</span> <span class="o">(</span><span class="n">containsOp</span><span class="o">(</span><span class="n">FOREVER</span><span class="o">))</span> <span class="o">{</span> <span class="n">timeout</span> <span class="o">=</span> <span class="mi">0</span><span class="o">;</span> <span class="o">}</span>
+ <span class="k">if</span> <span class="o">(</span><span class="n">containsOp</span><span class="o">(</span><span class="n">COUNT</span><span class="o">))</span> <span class="o">{</span> <span class="n">count</span> <span class="o">=</span> <span class="n">Integer</span><span class="o">.</span><span class="na">parseInt</span><span class="o">(</span><span class="n">getOp</span><span class="o">(</span><span class="n">COUNT</span><span class="o">));</span> <span class="o">}</span>
+
+ <span class="k">while</span> <span class="o">((</span><span class="n">msg</span> <span class="o">=</span> <span class="n">consumer</span><span class="o">.</span><span class="na">receive</span><span class="o">(</span><span class="n">timeout</span><span class="o">))</span> <span class="o">!=</span> <span class="kc">null</span><span class="o">)</span>
+ <span class="o">{</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"\n------------- Msg -------------"</span><span class="o">);</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="n">msg</span><span class="o">);</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"-------------------------------\n"</span><span class="o">);</span>
+
+ <span class="k">if</span> <span class="o">(</span><span class="n">count</span> <span class="o">></span> <span class="mi">0</span><span class="o">)</span> <span class="o">{</span>
+ <span class="k">if</span> <span class="o">(++</span><span class="n">i</span> <span class="o">==</span> <span class="n">count</span><span class="o">)</span> <span class="o">{</span>
+ <span class="k">break</span><span class="o">;</span>
+ <span class="o">}</span>
+ <span class="o">}</span>
+ <span class="o">}</span>
+ <span class="n">consumer</span><span class="o">.</span><span class="na">close</span><span class="o">();</span>
+ <span class="n">ssn</span><span class="o">.</span><span class="na">close</span><span class="o">();</span>
+ <span class="n">con</span><span class="o">.</span><span class="na">close</span><span class="o">();</span>
+ <span class="o">}</span>
+
+ <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span>
+ <span class="o">{</span>
+ <span class="n">String</span> <span class="n">u</span> <span class="o">=</span> <span class="s">"Usage: drain [OPTIONS] 'ADDRESS'"</span><span class="o">;</span>
+ <span class="n">String</span> <span class="n">d</span> <span class="o">=</span> <span class="s">"Drains messages from the specified address."</span><span class="o">;</span>
+
+ <span class="k">new</span> <span class="n">Drain</span><span class="o">(</span><span class="n">args</span><span class="o">,</span><span class="n">u</span><span class="o">,</span><span class="n">d</span><span class="o">);</span>
+ <span class="o">}</span>
+<span class="o">}</span>
+</pre></div>
+
+<p><a href="Drain.java">Download this file</a></p>
+
+
+ <hr/>
+
+ <ul id="-apache-navigation">
+ <li><a href="http://www.apache.org/">Apache</a></li>
+ <li><a href="http://www.apache.org/licenses/">License</a></li>
+ <li><a href="http://www.apache.org/foundation/sponsorship.html">Sponsorship</a></li>
+ <li><a href="http://www.apache.org/foundation/thanks.html">Thanks!</a></li>
+ <li><a href="/security.html">Security</a></li>
+ <li><a href="http://www.apache.org/"><img id="-apache-feather" width="48" height="14" src="" alt="Apache"/></a></li>
+ </ul>
+
+ <p id="-legal">
+ Apache Qpid, Messaging built on AMQP; Copyright © 2015
+ The Apache Software Foundation; Licensed under
+ the <a href="http://www.apache.org/licenses/LICENSE-2.0">Apache
+ License, Version 2.0</a>; Apache Qpid, Qpid, Qpid Proton,
+ Proton, Apache, the Apache feather logo, and the Apache Qpid
+ project logo are trademarks of The Apache Software
+ Foundation; All other marks mentioned may be trademarks or
+ registered trademarks of their respective owners
+ </p>
+ </div>
+ </div>
+ </div>
+ </body>
+</html>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/1c801de7/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/Hello.java
----------------------------------------------------------------------
diff --git a/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/Hello.java b/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/Hello.java
new file mode 100755
index 0000000..109a72b
--- /dev/null
+++ b/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/Hello.java
@@ -0,0 +1,83 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+package org.apache.qpid.example;
+
+import java.io.InputStream;
+import java.util.Properties;
+
+import javax.jms.Connection;
+import javax.jms.ConnectionFactory;
+import javax.jms.Destination;
+import javax.jms.MessageConsumer;
+import javax.jms.MessageProducer;
+import javax.jms.Session;
+import javax.jms.TextMessage;
+import javax.naming.Context;
+import javax.naming.InitialContext;
+
+
+public class Hello
+{
+
+ public Hello()
+ {
+ }
+
+ public static void main(String[] args)
+ {
+ Hello hello = new Hello();
+ hello.runTest();
+ }
+
+ private void runTest()
+ {
+ try (InputStream resourceAsStream = this.getClass().getResourceAsStream("hello.properties"))
+ {
+ Properties properties = new Properties();
+ properties.load(resourceAsStream);
+ Context context = new InitialContext(properties);
+
+ ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("qpidConnectionfactory");
+ Connection connection = connectionFactory.createConnection();
+ connection.start();
+
+ Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+ Destination destination = (Destination) context.lookup("topicExchange");
+
+ MessageProducer messageProducer = session.createProducer(destination);
+ MessageConsumer messageConsumer = session.createConsumer(destination);
+
+ TextMessage message = session.createTextMessage("Hello world!");
+ messageProducer.send(message);
+
+ message = (TextMessage)messageConsumer.receive();
+ System.out.println(message.getText());
+
+ connection.close();
+ context.close();
+ }
+ catch (Exception exp)
+ {
+ exp.printStackTrace();
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/1c801de7/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/Hello.java.html
----------------------------------------------------------------------
diff --git a/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/Hello.java.html b/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/Hello.java.html
new file mode 100644
index 0000000..a584877
--- /dev/null
+++ b/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/Hello.java.html
@@ -0,0 +1,211 @@
+<!DOCTYPE html>
+<!--
+ -
+ - Licensed to the Apache Software Foundation (ASF) under one
+ - or more contributor license agreements. See the NOTICE file
+ - distributed with this work for additional information
+ - regarding copyright ownership. The ASF licenses this file
+ - to you under the Apache License, Version 2.0 (the
+ - "License"); you may not use this file except in compliance
+ - with the License. You may obtain a copy of the License at
+ -
+ - http://www.apache.org/licenses/LICENSE-2.0
+ -
+ - Unless required by applicable law or agreed to in writing,
+ - software distributed under the License is distributed on an
+ - "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ - KIND, either express or implied. See the License for the
+ - specific language governing permissions and limitations
+ - under the License.
+ -
+-->
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en">
+ <head>
+ <title>Hello.java - Apache Qpid™</title>
+ <meta http-equiv="X-UA-Compatible" content="IE=edge"/>
+ <meta name="viewport" content="width=device-width, initial-scale=1.0"/>
+ <link rel="stylesheet" href="/site.css" type="text/css" async="async"/>
+ <link rel="stylesheet" href="/deferred.css" type="text/css" defer="defer"/>
+ <script type="text/javascript">var _deferredFunctions = [];</script>
+ <script type="text/javascript" src="/deferred.js" defer="defer"></script>
+ <!--[if lte IE 8]>
+ <link rel="stylesheet" href="/ie.css" type="text/css"/>
+ <script type="text/javascript" src="/html5shiv.js"></script>
+ <![endif]-->
+
+ <!-- Redirects for `go get` and godoc.org -->
+ <meta name="go-import"
+ content="qpid.apache.org git https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+ <meta name="go-source"
+ content="qpid.apache.org
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+ </head>
+ <body>
+ <div id="-content">
+ <div id="-top" class="panel">
+ <a id="-menu-link"><img width="16" height="16" src="" alt="Menu"/></a>
+
+ <a id="-search-link"><img width="22" height="16" src="" alt="Search"/></a>
+
+ <ul id="-global-navigation">
+ <li><a id="-logotype" href="/index.html">Apache Qpid<sup>™</sup></a></li>
+ <li><a href="/documentation.html">Documentation</a></li>
+ <li><a href="/download.html">Download</a></li>
+ <li><a href="/discussion.html">Discussion</a></li>
+ </ul>
+ </div>
+
+ <div id="-menu" class="panel" style="display: none;">
+ <div class="flex">
+ <section>
+ <h3>Project</h3>
+
+ <ul>
+ <li><a href="/overview.html">Overview</a></li>
+ <li><a href="/components/index.html">Components</a></li>
+ <li><a href="/releases/index.html">Releases</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Messaging APIs</h3>
+
+ <ul>
+ <li><a href="/proton/index.html">Qpid Proton</a></li>
+ <li><a href="/components/jms/index.html">Qpid JMS</a></li>
+ <li><a href="/components/messaging-api/index.html">Qpid Messaging API</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Servers and tools</h3>
+
+ <ul>
+ <li><a href="/components/broker-j/index.html">Broker-J</a></li>
+ <li><a href="/components/cpp-broker/index.html">C++ broker</a></li>
+ <li><a href="/components/dispatch-router/index.html">Dispatch router</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Resources</h3>
+
+ <ul>
+ <li><a href="/dashboard.html">Dashboard</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/qpid/Index">Wiki</a></li>
+ <li><a href="/resources.html">More resources</a></li>
+ </ul>
+ </section>
+ </div>
+ </div>
+
+ <div id="-search" class="panel" style="display: none;">
+ <form action="http://www.google.com/search" method="get">
+ <input type="hidden" name="sitesearch" value="qpid.apache.org"/>
+ <input type="text" name="q" maxlength="255" autofocus="autofocus" tabindex="1"/>
+ <button type="submit">Search</button>
+ <a href="/search.html">More ways to search</a>
+ </form>
+ </div>
+
+ <div id="-middle" class="panel">
+ <ul id="-path-navigation"><li><a href="/index.html">Home</a></li><li><a href="/releases/index.html">Releases</a></li><li><a href="/releases/qpid-jms-amqp-0-x-6.3.0/index.html">Qpid JMS AMQP 0-x 6.3.0</a></li><li><a href="/releases/qpid-jms-amqp-0-x-6.3.0/examples/index.html">Qpid JMS AMQP 0-x Examples</a></li><li>Hello.java</li></ul>
+
+ <div id="-middle-content">
+
+<h1>Hello.java</h1>
+<div class="highlight"><pre><span></span><span class="kn">package</span> <span class="nn">org.apache.qpid.example</span><span class="o">;</span>
+
+<span class="kn">import</span> <span class="nn">java.io.InputStream</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">java.util.Properties</span><span class="o">;</span>
+
+<span class="kn">import</span> <span class="nn">javax.jms.Connection</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.jms.ConnectionFactory</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.jms.Destination</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.jms.MessageConsumer</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.jms.MessageProducer</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.jms.Session</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.jms.TextMessage</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.naming.Context</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.naming.InitialContext</span><span class="o">;</span>
+
+
+<span class="kd">public</span> <span class="kd">class</span> <span class="nc">Hello</span>
+<span class="o">{</span>
+
+ <span class="kd">public</span> <span class="nf">Hello</span><span class="o">()</span>
+ <span class="o">{</span>
+ <span class="o">}</span>
+
+ <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span>
+ <span class="o">{</span>
+ <span class="n">Hello</span> <span class="n">hello</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Hello</span><span class="o">();</span>
+ <span class="n">hello</span><span class="o">.</span><span class="na">runTest</span><span class="o">();</span>
+ <span class="o">}</span>
+
+ <span class="kd">private</span> <span class="kt">void</span> <span class="nf">runTest</span><span class="o">()</span>
+ <span class="o">{</span>
+ <span class="k">try</span> <span class="o">(</span><span class="n">InputStream</span> <span class="n">resourceAsStream</span> <span class="o">=</span> <span class="k">this</span><span class="o">.</span><span class="na">getClass</span><span class="o">().</span><span class="na">getResourceAsStream</span><span class="o">(</span><span class="s">"hello.properties"</span><span class="o">))</span>
+ <span class="o">{</span>
+ <span class="n">Properties</span> <span class="n">properties</span> <span class="o">=</span> <span class="k">new</span> <span class="n">Properties</span><span class="o">();</span>
+ <span class="n">properties</span><span class="o">.</span><span class="na">load</span><span class="o">(</span><span class="n">resourceAsStream</span><span class="o">);</span>
+ <span class="n">Context</span> <span class="n">context</span> <span class="o">=</span> <span class="k">new</span> <span class="n">InitialContext</span><span class="o">(</span><span class="n">properties</span><span class="o">);</span>
+
+ <span class="n">ConnectionFactory</span> <span class="n">connectionFactory</span> <span class="o">=</span> <span class="o">(</span><span class="n">ConnectionFactory</span><span class="o">)</span> <span class="n">context</span><span class="o">.</span><span class="na">lookup</span><span class="o">(</span><span class="s">"qpidConnectionfactory"</span><span class="o">);</span>
+ <span class="n">Connection</span> <span class="n">connection</span> <span class="o">=</span> <span class="n">connectionFactory</span><span class="o">.</span><span class="na">createConnection</span><span class="o">();</span>
+ <span class="n">connection</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>
+
+ <span class="n">Session</span> <span class="n">session</span> <span class="o">=</span> <span class="n">connection</span><span class="o">.</span><span class="na">createSession</span><span class="o">(</span><span class="kc">false</span><span class="o">,</span> <span class="n">Session</span><span class="o">.</span><span class="na">AUTO_ACKNOWLEDGE</span><span class="o">);</span>
+ <span class="n">Destination</span> <span class="n">destination</span> <span class="o">=</span> <span class="o">(</span><span class="n">Destination</span><span class="o">)</span> <span class="n">context</span><span class="o">.</span><span class="na">lookup</span><span class="o">(</span><span class="s">"topicExchange"</span><span class="o">);</span>
+
+ <span class="n">MessageProducer</span> <span class="n">messageProducer</span> <span class="o">=</span> <span class="n">session</span><span class="o">.</span><span class="na">createProducer</span><span class="o">(</span><span class="n">destination</span><span class="o">);</span>
+ <span class="n">MessageConsumer</span> <span class="n">messageConsumer</span> <span class="o">=</span> <span class="n">session</span><span class="o">.</span><span class="na">createConsumer</span><span class="o">(</span><span class="n">destination</span><span class="o">);</span>
+
+ <span class="n">TextMessage</span> <span class="n">message</span> <span class="o">=</span> <span class="n">session</span><span class="o">.</span><span class="na">createTextMessage</span><span class="o">(</span><span class="s">"Hello world!"</span><span class="o">);</span>
+ <span class="n">messageProducer</span><span class="o">.</span><span class="na">send</span><span class="o">(</span><span class="n">message</span><span class="o">);</span>
+
+ <span class="n">message</span> <span class="o">=</span> <span class="o">(</span><span class="n">TextMessage</span><span class="o">)</span><span class="n">messageConsumer</span><span class="o">.</span><span class="na">receive</span><span class="o">();</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="n">message</span><span class="o">.</span><span class="na">getText</span><span class="o">());</span>
+
+ <span class="n">connection</span><span class="o">.</span><span class="na">close</span><span class="o">();</span>
+ <span class="n">context</span><span class="o">.</span><span class="na">close</span><span class="o">();</span>
+ <span class="o">}</span>
+ <span class="k">catch</span> <span class="o">(</span><span class="n">Exception</span> <span class="n">exp</span><span class="o">)</span>
+ <span class="o">{</span>
+ <span class="n">exp</span><span class="o">.</span><span class="na">printStackTrace</span><span class="o">();</span>
+ <span class="o">}</span>
+ <span class="o">}</span>
+<span class="o">}</span>
+</pre></div>
+
+<p><a href="Hello.java">Download this file</a></p>
+
+
+ <hr/>
+
+ <ul id="-apache-navigation">
+ <li><a href="http://www.apache.org/">Apache</a></li>
+ <li><a href="http://www.apache.org/licenses/">License</a></li>
+ <li><a href="http://www.apache.org/foundation/sponsorship.html">Sponsorship</a></li>
+ <li><a href="http://www.apache.org/foundation/thanks.html">Thanks!</a></li>
+ <li><a href="/security.html">Security</a></li>
+ <li><a href="http://www.apache.org/"><img id="-apache-feather" width="48" height="14" src="" alt="Apache"/></a></li>
+ </ul>
+
+ <p id="-legal">
+ Apache Qpid, Messaging built on AMQP; Copyright © 2015
+ The Apache Software Foundation; Licensed under
+ the <a href="http://www.apache.org/licenses/LICENSE-2.0">Apache
+ License, Version 2.0</a>; Apache Qpid, Qpid, Qpid Proton,
+ Proton, Apache, the Apache feather logo, and the Apache Qpid
+ project logo are trademarks of The Apache Software
+ Foundation; All other marks mentioned may be trademarks or
+ registered trademarks of their respective owners
+ </p>
+ </div>
+ </div>
+ </div>
+ </body>
+</html>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/1c801de7/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/ListReceiver.java
----------------------------------------------------------------------
diff --git a/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/ListReceiver.java b/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/ListReceiver.java
new file mode 100755
index 0000000..b12cfab
--- /dev/null
+++ b/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/ListReceiver.java
@@ -0,0 +1,101 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+package org.apache.qpid.example;
+
+import javax.jms.Connection;
+import javax.jms.Destination;
+import javax.jms.MapMessage;
+import javax.jms.StreamMessage;
+import javax.jms.MessageConsumer;
+import javax.jms.Session;
+import javax.jms.MessageEOFException;
+
+import org.apache.qpid.client.AMQAnyDestination;
+import org.apache.qpid.client.AMQConnection;
+
+import org.apache.qpid.jms.ListMessage;
+
+import java.util.Enumeration;
+import java.util.Iterator;
+
+public class ListReceiver {
+
+ public static void main(String[] args) throws Exception
+ {
+ if (args.length != 1) {
+ System.out.println("Usage: java org.apache.qpid.example.ListReceiver <-l | -m | -s>");
+ System.out.println("where:");
+ System.out.println("\t-l\tAccept ListMessage and print it");
+ System.out.println("\t-m\tAccept ListMessage as a MapMessage");
+ System.out.println("\t-s\tAccept ListMessage as a StreamMessage");
+ return;
+ }
+
+ Connection connection =
+ new AMQConnection("amqp://guest:guest@test/?brokerlist='tcp://localhost:5672'");
+
+ connection.start();
+
+ Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+ Destination queue = new AMQAnyDestination("ADDR:message_queue; {create: always}");
+ MessageConsumer consumer = session.createConsumer(queue);
+
+ if (args[0].equals("-l")) {
+ System.out.println("Receiving as ListMessage");
+ ListMessage m = (ListMessage)consumer.receive();
+ System.out.println(m);
+ System.out.println("==========================================");
+ System.out.println("Printing list contents:");
+ Iterator i = m.iterator();
+ while(i.hasNext())
+ System.out.println(i.next());
+ }
+ else if (args[0].equals("-m")) {
+ System.out.println("Receiving as MapMessage");
+ MapMessage m = (MapMessage)consumer.receive();
+ System.out.println(m);
+ System.out.println("==========================================");
+ System.out.println("Printing map contents:");
+ Enumeration keys = m.getMapNames();
+ while(keys.hasMoreElements()) {
+ String key = (String)keys.nextElement();
+ System.out.println(key + " => " + m.getObject(key));
+ }
+ }
+ else if (args[0].equals("-s")) {
+ System.out.println("Receiving as StreamMessage");
+ StreamMessage m = (StreamMessage)consumer.receive();
+ System.out.println(m);
+ System.out.println("==========================================");
+ System.out.println("Printing stream contents:");
+ try {
+ while(true)
+ System.out.println(m.readObject());
+ }
+ catch (MessageEOFException e) {
+ // DONE
+ }
+ }
+
+ connection.close();
+ }
+}
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/1c801de7/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/ListReceiver.java.html
----------------------------------------------------------------------
diff --git a/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/ListReceiver.java.html b/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/ListReceiver.java.html
new file mode 100644
index 0000000..680e7d0
--- /dev/null
+++ b/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/ListReceiver.java.html
@@ -0,0 +1,229 @@
+<!DOCTYPE html>
+<!--
+ -
+ - Licensed to the Apache Software Foundation (ASF) under one
+ - or more contributor license agreements. See the NOTICE file
+ - distributed with this work for additional information
+ - regarding copyright ownership. The ASF licenses this file
+ - to you under the Apache License, Version 2.0 (the
+ - "License"); you may not use this file except in compliance
+ - with the License. You may obtain a copy of the License at
+ -
+ - http://www.apache.org/licenses/LICENSE-2.0
+ -
+ - Unless required by applicable law or agreed to in writing,
+ - software distributed under the License is distributed on an
+ - "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ - KIND, either express or implied. See the License for the
+ - specific language governing permissions and limitations
+ - under the License.
+ -
+-->
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en">
+ <head>
+ <title>ListReceiver.java - Apache Qpid™</title>
+ <meta http-equiv="X-UA-Compatible" content="IE=edge"/>
+ <meta name="viewport" content="width=device-width, initial-scale=1.0"/>
+ <link rel="stylesheet" href="/site.css" type="text/css" async="async"/>
+ <link rel="stylesheet" href="/deferred.css" type="text/css" defer="defer"/>
+ <script type="text/javascript">var _deferredFunctions = [];</script>
+ <script type="text/javascript" src="/deferred.js" defer="defer"></script>
+ <!--[if lte IE 8]>
+ <link rel="stylesheet" href="/ie.css" type="text/css"/>
+ <script type="text/javascript" src="/html5shiv.js"></script>
+ <![endif]-->
+
+ <!-- Redirects for `go get` and godoc.org -->
+ <meta name="go-import"
+ content="qpid.apache.org git https://git-wip-us.apache.org/repos/asf/qpid-proton.git"/>
+ <meta name="go-source"
+ content="qpid.apache.org
+https://github.com/apache/qpid-proton/blob/go1/README.md
+https://github.com/apache/qpid-proton/tree/go1{/dir}
+https://github.com/apache/qpid-proton/blob/go1{/dir}/{file}#L{line}"/>
+ </head>
+ <body>
+ <div id="-content">
+ <div id="-top" class="panel">
+ <a id="-menu-link"><img width="16" height="16" src="" alt="Menu"/></a>
+
+ <a id="-search-link"><img width="22" height="16" src="" alt="Search"/></a>
+
+ <ul id="-global-navigation">
+ <li><a id="-logotype" href="/index.html">Apache Qpid<sup>™</sup></a></li>
+ <li><a href="/documentation.html">Documentation</a></li>
+ <li><a href="/download.html">Download</a></li>
+ <li><a href="/discussion.html">Discussion</a></li>
+ </ul>
+ </div>
+
+ <div id="-menu" class="panel" style="display: none;">
+ <div class="flex">
+ <section>
+ <h3>Project</h3>
+
+ <ul>
+ <li><a href="/overview.html">Overview</a></li>
+ <li><a href="/components/index.html">Components</a></li>
+ <li><a href="/releases/index.html">Releases</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Messaging APIs</h3>
+
+ <ul>
+ <li><a href="/proton/index.html">Qpid Proton</a></li>
+ <li><a href="/components/jms/index.html">Qpid JMS</a></li>
+ <li><a href="/components/messaging-api/index.html">Qpid Messaging API</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Servers and tools</h3>
+
+ <ul>
+ <li><a href="/components/broker-j/index.html">Broker-J</a></li>
+ <li><a href="/components/cpp-broker/index.html">C++ broker</a></li>
+ <li><a href="/components/dispatch-router/index.html">Dispatch router</a></li>
+ </ul>
+ </section>
+
+ <section>
+ <h3>Resources</h3>
+
+ <ul>
+ <li><a href="/dashboard.html">Dashboard</a></li>
+ <li><a href="https://cwiki.apache.org/confluence/display/qpid/Index">Wiki</a></li>
+ <li><a href="/resources.html">More resources</a></li>
+ </ul>
+ </section>
+ </div>
+ </div>
+
+ <div id="-search" class="panel" style="display: none;">
+ <form action="http://www.google.com/search" method="get">
+ <input type="hidden" name="sitesearch" value="qpid.apache.org"/>
+ <input type="text" name="q" maxlength="255" autofocus="autofocus" tabindex="1"/>
+ <button type="submit">Search</button>
+ <a href="/search.html">More ways to search</a>
+ </form>
+ </div>
+
+ <div id="-middle" class="panel">
+ <ul id="-path-navigation"><li><a href="/index.html">Home</a></li><li><a href="/releases/index.html">Releases</a></li><li><a href="/releases/qpid-jms-amqp-0-x-6.3.0/index.html">Qpid JMS AMQP 0-x 6.3.0</a></li><li><a href="/releases/qpid-jms-amqp-0-x-6.3.0/examples/index.html">Qpid JMS AMQP 0-x Examples</a></li><li>ListReceiver.java</li></ul>
+
+ <div id="-middle-content">
+
+<h1>ListReceiver.java</h1>
+<div class="highlight"><pre><span></span><span class="kn">package</span> <span class="nn">org.apache.qpid.example</span><span class="o">;</span>
+
+<span class="kn">import</span> <span class="nn">javax.jms.Connection</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.jms.Destination</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.jms.MapMessage</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.jms.StreamMessage</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.jms.MessageConsumer</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.jms.Session</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">javax.jms.MessageEOFException</span><span class="o">;</span>
+
+<span class="kn">import</span> <span class="nn">org.apache.qpid.client.AMQAnyDestination</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">org.apache.qpid.client.AMQConnection</span><span class="o">;</span>
+
+<span class="kn">import</span> <span class="nn">org.apache.qpid.jms.ListMessage</span><span class="o">;</span>
+
+<span class="kn">import</span> <span class="nn">java.util.Enumeration</span><span class="o">;</span>
+<span class="kn">import</span> <span class="nn">java.util.Iterator</span><span class="o">;</span>
+
+<span class="kd">public</span> <span class="kd">class</span> <span class="nc">ListReceiver</span> <span class="o">{</span>
+
+ <span class="kd">public</span> <span class="kd">static</span> <span class="kt">void</span> <span class="nf">main</span><span class="o">(</span><span class="n">String</span><span class="o">[]</span> <span class="n">args</span><span class="o">)</span> <span class="kd">throws</span> <span class="n">Exception</span>
+ <span class="o">{</span>
+ <span class="k">if</span> <span class="o">(</span><span class="n">args</span><span class="o">.</span><span class="na">length</span> <span class="o">!=</span> <span class="mi">1</span><span class="o">)</span> <span class="o">{</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"Usage: java org.apache.qpid.example.ListReceiver <-l | -m | -s>"</span><span class="o">);</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"where:"</span><span class="o">);</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"\t-l\tAccept ListMessage and print it"</span><span class="o">);</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"\t-m\tAccept ListMessage as a MapMessage"</span><span class="o">);</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"\t-s\tAccept ListMessage as a StreamMessage"</span><span class="o">);</span>
+ <span class="k">return</span><span class="o">;</span>
+ <span class="o">}</span>
+
+ <span class="n">Connection</span> <span class="n">connection</span> <span class="o">=</span>
+ <span class="k">new</span> <span class="n">AMQConnection</span><span class="o">(</span><span class="s">"amqp://guest:guest@test/?brokerlist='tcp://localhost:5672'"</span><span class="o">);</span>
+
+ <span class="n">connection</span><span class="o">.</span><span class="na">start</span><span class="o">();</span>
+
+ <span class="n">Session</span> <span class="n">session</span> <span class="o">=</span> <span class="n">connection</span><span class="o">.</span><span class="na">createSession</span><span class="o">(</span><span class="kc">false</span><span class="o">,</span> <span class="n">Session</span><span class="o">.</span><span class="na">AUTO_ACKNOWLEDGE</span><span class="o">);</span>
+ <span class="n">Destination</span> <span class="n">queue</span> <span class="o">=</span> <span class="k">new</span> <span class="n">AMQAnyDestination</span><span class="o">(</span><span class="s">"ADDR:message_queue; {create: always}"</span><span class="o">);</span>
+ <span class="n">MessageConsumer</span> <span class="n">consumer</span> <span class="o">=</span> <span class="n">session</span><span class="o">.</span><span class="na">createConsumer</span><span class="o">(</span><span class="n">queue</span><span class="o">);</span>
+
+ <span class="k">if</span> <span class="o">(</span><span class="n">args</span><span class="o">[</span><span class="mi">0</span><span class="o">].</span><span class="na">equals</span><span class="o">(</span><span class="s">"-l"</span><span class="o">))</span> <span class="o">{</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"Receiving as ListMessage"</span><span class="o">);</span>
+ <span class="n">ListMessage</span> <span class="n">m</span> <span class="o">=</span> <span class="o">(</span><span class="n">ListMessage</span><span class="o">)</span><span class="n">consumer</span><span class="o">.</span><span class="na">receive</span><span class="o">();</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="n">m</span><span class="o">);</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"=========================================="</span><span class="o">);</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"Printing list contents:"</span><span class="o">);</span>
+ <span class="n">Iterator</span> <span class="n">i</span> <span class="o">=</span> <span class="n">m</span><span class="o">.</span><span class="na">iterator</span><span class="o">();</span>
+ <span class="k">while</span><span class="o">(</span><span class="n">i</span><span class="o">.</span><span class="na">hasNext</span><span class="o">())</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="n">i</span><span class="o">.</span><span class="na">next</span><span class="o">());</span>
+ <span class="o">}</span>
+ <span class="k">else</span> <span class="k">if</span> <span class="o">(</span><span class="n">args</span><span class="o">[</span><span class="mi">0</span><span class="o">].</span><span class="na">equals</span><span class="o">(</span><span class="s">"-m"</span><span class="o">))</span> <span class="o">{</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"Receiving as MapMessage"</span><span class="o">);</span>
+ <span class="n">MapMessage</span> <span class="n">m</span> <span class="o">=</span> <span class="o">(</span><span class="n">MapMessage</span><span class="o">)</span><span class="n">consumer</span><span class="o">.</span><span class="na">receive</span><span class="o">();</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="n">m</span><span class="o">);</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"=========================================="</span><span class="o">);</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"Printing map contents:"</span><span class="o">);</span>
+ <span class="n">Enumeration</span> <span class="n">keys</span> <span class="o">=</span> <span class="n">m</span><span class="o">.</span><span class="na">getMapNames</span><span class="o">();</span>
+ <span class="k">while</span><span class="o">(</span><span class="n">keys</span><span class="o">.</span><span class="na">hasMoreElements</span><span class="o">())</span> <span class="o">{</span>
+ <span class="n">String</span> <span class="n">key</span> <span class="o">=</span> <span class="o">(</span><span class="n">String</span><span class="o">)</span><span class="n">keys</span><span class="o">.</span><span class="na">nextElement</span><span class="o">();</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="n">key</span> <span class="o">+</span> <span class="s">" => "</span> <span class="o">+</span> <span class="n">m</span><span class="o">.</span><span class="na">getObject</span><span class="o">(</span><span class="n">key</span><span class="o">));</span>
+ <span class="o">}</span>
+ <span class="o">}</span>
+ <span class="k">else</span> <span class="k">if</span> <span class="o">(</span><span class="n">args</span><span class="o">[</span><span class="mi">0</span><span class="o">].</span><span class="na">equals</span><span class="o">(</span><span class="s">"-s"</span><span class="o">))</span> <span class="o">{</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"Receiving as StreamMessage"</span><span class="o">);</span>
+ <span class="n">StreamMessage</span> <span class="n">m</span> <span class="o">=</span> <span class="o">(</span><span class="n">StreamMessage</span><span class="o">)</span><span class="n">consumer</span><span class="o">.</span><span class="na">receive</span><span class="o">();</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="n">m</span><span class="o">);</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"=========================================="</span><span class="o">);</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="s">"Printing stream contents:"</span><span class="o">);</span>
+ <span class="k">try</span> <span class="o">{</span>
+ <span class="k">while</span><span class="o">(</span><span class="kc">true</span><span class="o">)</span>
+ <span class="n">System</span><span class="o">.</span><span class="na">out</span><span class="o">.</span><span class="na">println</span><span class="o">(</span><span class="n">m</span><span class="o">.</span><span class="na">readObject</span><span class="o">());</span>
+ <span class="o">}</span>
+ <span class="k">catch</span> <span class="o">(</span><span class="n">MessageEOFException</span> <span class="n">e</span><span class="o">)</span> <span class="o">{</span>
+ <span class="c1">// DONE</span>
+ <span class="o">}</span>
+ <span class="o">}</span>
+
+ <span class="n">connection</span><span class="o">.</span><span class="na">close</span><span class="o">();</span>
+ <span class="o">}</span>
+<span class="o">}</span>
+</pre></div>
+
+<p><a href="ListReceiver.java">Download this file</a></p>
+
+
+ <hr/>
+
+ <ul id="-apache-navigation">
+ <li><a href="http://www.apache.org/">Apache</a></li>
+ <li><a href="http://www.apache.org/licenses/">License</a></li>
+ <li><a href="http://www.apache.org/foundation/sponsorship.html">Sponsorship</a></li>
+ <li><a href="http://www.apache.org/foundation/thanks.html">Thanks!</a></li>
+ <li><a href="/security.html">Security</a></li>
+ <li><a href="http://www.apache.org/"><img id="-apache-feather" width="48" height="14" src="" alt="Apache"/></a></li>
+ </ul>
+
+ <p id="-legal">
+ Apache Qpid, Messaging built on AMQP; Copyright © 2015
+ The Apache Software Foundation; Licensed under
+ the <a href="http://www.apache.org/licenses/LICENSE-2.0">Apache
+ License, Version 2.0</a>; Apache Qpid, Qpid, Qpid Proton,
+ Proton, Apache, the Apache feather logo, and the Apache Qpid
+ project logo are trademarks of The Apache Software
+ Foundation; All other marks mentioned may be trademarks or
+ registered trademarks of their respective owners
+ </p>
+ </div>
+ </div>
+ </div>
+ </body>
+</html>
http://git-wip-us.apache.org/repos/asf/qpid-site/blob/1c801de7/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/ListSender.java
----------------------------------------------------------------------
diff --git a/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/ListSender.java b/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/ListSender.java
new file mode 100755
index 0000000..fe2c1ec
--- /dev/null
+++ b/content/releases/qpid-jms-amqp-0-x-6.3.0/examples/ListSender.java
@@ -0,0 +1,86 @@
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+
+package org.apache.qpid.example;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import javax.jms.Connection;
+import javax.jms.Destination;
+import javax.jms.Message;
+import javax.jms.MessageProducer;
+import javax.jms.Session;
+
+import org.apache.qpid.client.AMQAnyDestination;
+import org.apache.qpid.client.AMQConnection;
+
+import org.apache.qpid.jms.ListMessage;
+
+
+public class ListSender {
+
+ public static void main(String[] args) throws Exception
+ {
+ Connection connection =
+ new AMQConnection("amqp://guest:guest@test/?brokerlist='tcp://localhost:5672'");
+
+ Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+ Destination queue = new AMQAnyDestination("ADDR:message_queue; {create: always}");
+ MessageProducer producer = session.createProducer(queue);
+
+ ListMessage m = ((org.apache.qpid.jms.Session)session).createListMessage();
+ m.setIntProperty("Id", 987654321);
+ m.setStringProperty("name", "Widget");
+ m.setDoubleProperty("price", 0.99);
+
+ List<String> colors = new ArrayList<String>();
+ colors.add("red");
+ colors.add("green");
+ colors.add("white");
+ m.add(colors);
+
+ Map<String,Double> dimensions = new HashMap<String,Double>();
+ dimensions.put("length",10.2);
+ dimensions.put("width",5.1);
+ dimensions.put("depth",2.0);
+ m.add(dimensions);
+
+ List<List<Integer>> parts = new ArrayList<List<Integer>>();
+ parts.add(Arrays.asList(new Integer[] {1,2,5}));
+ parts.add(Arrays.asList(new Integer[] {8,2,5}));
+ m.add(parts);
+
+ Map<String,Object> specs = new HashMap<String,Object>();
+ specs.put("colours", colors);
+ specs.put("dimensions", dimensions);
+ specs.put("parts", parts);
+ m.add(specs);
+
+ producer.send((Message)m);
+ System.out.println("Sent: " + m);
+ connection.close();
+ }
+
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org