Return-Path: X-Original-To: apmail-activemq-commits-archive@www.apache.org Delivered-To: apmail-activemq-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 71F5910963 for ; Wed, 10 Dec 2014 16:11:30 +0000 (UTC) Received: (qmail 14243 invoked by uid 500); 10 Dec 2014 16:11:29 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 14193 invoked by uid 500); 10 Dec 2014 16:11:29 -0000 Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list commits@activemq.apache.org Received: (qmail 13102 invoked by uid 99); 10 Dec 2014 16:11:28 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 10 Dec 2014 16:11:28 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id C8BC2A23D6E; Wed, 10 Dec 2014 16:11:28 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: jbertram@apache.org To: commits@activemq.apache.org Date: Wed, 10 Dec 2014 16:11:54 -0000 Message-Id: <10200e5913e24eaab215d58a00bde6d0@git.apache.org> In-Reply-To: <34f402ddf8314dd6a70969b26485f39b@git.apache.org> References: <34f402ddf8314dd6a70969b26485f39b@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [28/37] activemq-6 git commit: ACTIVEMQ6-51 Example server bootstrapping http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/expiry/src/main/resources/hornetq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/expiry/src/main/resources/hornetq/server0/activemq-configuration.xml b/examples/jms/expiry/src/main/resources/hornetq/server0/activemq-configuration.xml deleted file mode 100644 index 7e44235..0000000 --- a/examples/jms/expiry/src/main/resources/hornetq/server0/activemq-configuration.xml +++ /dev/null @@ -1,50 +0,0 @@ - - - ${build.directory}/server0/data/messaging/bindings - - ${build.directory}/server0/data/messaging/journal - - ${build.directory}/server0/data/messaging/largemessages - - ${build.directory}/server0/data/messaging/paging - - - - - - - org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory - - - - - - - org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory - - - - - - - - - - - - - - - - - - - - - jms.queue.expiryQueue - - - - http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/expiry/src/main/resources/hornetq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/expiry/src/main/resources/hornetq/server0/activemq-jms.xml b/examples/jms/expiry/src/main/resources/hornetq/server0/activemq-jms.xml deleted file mode 100644 index d41da70..0000000 --- a/examples/jms/expiry/src/main/resources/hornetq/server0/activemq-jms.xml +++ /dev/null @@ -1,11 +0,0 @@ - - - - - - - - - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/expiry/src/main/resources/hornetq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/expiry/src/main/resources/hornetq/server0/activemq-users.xml b/examples/jms/expiry/src/main/resources/hornetq/server0/activemq-users.xml deleted file mode 100644 index ae30546..0000000 --- a/examples/jms/expiry/src/main/resources/hornetq/server0/activemq-users.xml +++ /dev/null @@ -1,7 +0,0 @@ - - - - - - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/expiry/src/main/resources/jndi.properties ---------------------------------------------------------------------- diff --git a/examples/jms/expiry/src/main/resources/jndi.properties b/examples/jms/expiry/src/main/resources/jndi.properties new file mode 100644 index 0000000..065794b --- /dev/null +++ b/examples/jms/expiry/src/main/resources/jndi.properties @@ -0,0 +1,4 @@ +java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory +java.naming.provider.url=tcp://localhost:5445 +queue.queue/exampleQueue=exampleQueue +queue.queue/expiryQueue=expiryQueue http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ha-policy-autobackup/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ha-policy-autobackup/pom.xml b/examples/jms/ha-policy-autobackup/pom.xml index 86f5d47..1056602 100644 --- a/examples/jms/ha-policy-autobackup/pom.xml +++ b/examples/jms/ha-policy-autobackup/pom.xml @@ -36,7 +36,7 @@ start - ${basedir}/target/classes/activemq/server0 + ${basedir}/target/classes/activemq/server0 udp-address @@ -53,7 +53,7 @@ 1199 1198 - ${basedir}/target/classes/activemq/server1 + ${basedir}/target/classes/activemq/server1 true @@ -88,7 +88,7 @@ stop - ${basedir}/target/classes/activemq/server0 + ${basedir}/target/classes/activemq/server0 @@ -97,7 +97,7 @@ stop - ${basedir}/target/classes/activemq/server1 + ${basedir}/target/classes/activemq/server1 http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ha-policy-autobackup/src/main/java/org/apache/activemq/jms/example/HAPolicyAutoBackupExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/ha-policy-autobackup/src/main/java/org/apache/activemq/jms/example/HAPolicyAutoBackupExample.java b/examples/jms/ha-policy-autobackup/src/main/java/org/apache/activemq/jms/example/HAPolicyAutoBackupExample.java index 3eebb40..4fbcdcb 100644 --- a/examples/jms/ha-policy-autobackup/src/main/java/org/apache/activemq/jms/example/HAPolicyAutoBackupExample.java +++ b/examples/jms/ha-policy-autobackup/src/main/java/org/apache/activemq/jms/example/HAPolicyAutoBackupExample.java @@ -16,6 +16,8 @@ */ package org.apache.activemq.jms.example; +import java.util.Hashtable; + import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.MessageConsumer; @@ -63,8 +65,24 @@ public class HAPolicyAutoBackupExample extends ActiveMQExample try { // Step 1. Get an initial context for looking up JNDI from server 0 and 1 - ic0 = getContext(0); - ic1 = getContext(1); + Hashtable properties = new Hashtable(); + properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory"); + properties.put("java.naming.provider.url", args[0]); + properties.put("queue.queue/exampleQueue", "exampleQueue"); + properties.put("connection.ConnectionFactory.ha", true); + properties.put("connection.ConnectionFactory.retryInterval", 1000); + properties.put("connection.ConnectionFactory.retryIntervalMultiplier", 1.0); + properties.put("connection.ConnectionFactory.reconnectAttempts", -1); + ic0 = new InitialContext(properties); + + properties = new Hashtable(); + properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory"); + properties.put("java.naming.provider.url", args[1]); + properties.put("connection.ConnectionFactory.ha", true); + properties.put("connection.ConnectionFactory.retryInterval", 1000); + properties.put("connection.ConnectionFactory.retryIntervalMultiplier", 1.0); + properties.put("connection.ConnectionFactory.reconnectAttempts", -1); + ic1 = new InitialContext(properties); // Step 2. Look-up the JMS Queue object from JNDI Queue queue = (Queue) ic0.lookup("queue/exampleQueue"); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server0/activemq-configuration.xml b/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server0/activemq-configuration.xml new file mode 100644 index 0000000..6a21e1d --- /dev/null +++ b/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server0/activemq-configuration.xml @@ -0,0 +1,93 @@ + + + target/server0/data/messaging/bindings + + target/server0/data/messaging/journal + + target/server0/data/messaging/largemessages + + target/server0/data/messaging/paging + + + + + org.apache.activemq.core.remoting.impl.invm.InVMConnectorFactory + + + org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory + + + + + org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory + + + + + + + + org.apache.activemq.core.remoting.impl.invm.InVMAcceptorFactory + + + org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory + + + + + + + + + 1 + true + 1000 + + invm-connector + server1-connector + netty-connector + + + + + + invm-connector + + + + + + + + + +
jms
+ netty-connector + 500 + true + true + 1 + + server1-connector + +
+
+ + + + + + + + + + + + + + + + +
\ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server0/activemq-jms.xml b/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server0/activemq-jms.xml new file mode 100644 index 0000000..847659f --- /dev/null +++ b/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server0/activemq-jms.xml @@ -0,0 +1,8 @@ + + + + + + \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server0/activemq-users.xml b/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server0/activemq-users.xml new file mode 100644 index 0000000..ae30546 --- /dev/null +++ b/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server0/activemq-users.xml @@ -0,0 +1,7 @@ + + + + + + \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server1/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server1/activemq-configuration.xml b/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server1/activemq-configuration.xml new file mode 100644 index 0000000..adaeb82 --- /dev/null +++ b/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server1/activemq-configuration.xml @@ -0,0 +1,93 @@ + + + target/server1/data/messaging/bindings + + target/server1/data/messaging/journal + + target/server1/data/messaging/largemessages + + target/server1/data/messaging/paging + + + + + org.apache.activemq.core.remoting.impl.invm.InVMConnectorFactory + + + org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory + + + + + org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory + + + + + + + + org.apache.activemq.core.remoting.impl.invm.InVMAcceptorFactory + + + org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory + + + + + + + + + 1 + true + 1000 + + invm-connector + server0-connector + netty-connector + + + + + + invm-connector + + + + + + + + + +
jms
+ netty-connector + 500 + true + true + 1 + + server0-connector + +
+
+ + + + + + + + + + + + + + + + +
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server1/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server1/activemq-jms.xml b/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server1/activemq-jms.xml new file mode 100644 index 0000000..847659f --- /dev/null +++ b/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server1/activemq-jms.xml @@ -0,0 +1,8 @@ + + + + + + \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server1/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server1/activemq-users.xml b/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server1/activemq-users.xml new file mode 100644 index 0000000..ae30546 --- /dev/null +++ b/examples/jms/ha-policy-autobackup/src/main/resources/activemq/server1/activemq-users.xml @@ -0,0 +1,7 @@ + + + + + + \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server0/activemq-configuration.xml b/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server0/activemq-configuration.xml deleted file mode 100644 index 6a21e1d..0000000 --- a/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server0/activemq-configuration.xml +++ /dev/null @@ -1,93 +0,0 @@ - - - target/server0/data/messaging/bindings - - target/server0/data/messaging/journal - - target/server0/data/messaging/largemessages - - target/server0/data/messaging/paging - - - - - org.apache.activemq.core.remoting.impl.invm.InVMConnectorFactory - - - org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory - - - - - org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory - - - - - - - - org.apache.activemq.core.remoting.impl.invm.InVMAcceptorFactory - - - org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory - - - - - - - - - 1 - true - 1000 - - invm-connector - server1-connector - netty-connector - - - - - - invm-connector - - - - - - - - - -
jms
- netty-connector - 500 - true - true - 1 - - server1-connector - -
-
- - - - - - - - - - - - - - - - -
\ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server0/activemq-jms.xml b/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server0/activemq-jms.xml deleted file mode 100644 index 847659f..0000000 --- a/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server0/activemq-jms.xml +++ /dev/null @@ -1,8 +0,0 @@ - - - - - - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server0/activemq-users.xml b/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server0/activemq-users.xml deleted file mode 100644 index ae30546..0000000 --- a/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server0/activemq-users.xml +++ /dev/null @@ -1,7 +0,0 @@ - - - - - - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server1/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server1/activemq-configuration.xml b/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server1/activemq-configuration.xml deleted file mode 100644 index adaeb82..0000000 --- a/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server1/activemq-configuration.xml +++ /dev/null @@ -1,93 +0,0 @@ - - - target/server1/data/messaging/bindings - - target/server1/data/messaging/journal - - target/server1/data/messaging/largemessages - - target/server1/data/messaging/paging - - - - - org.apache.activemq.core.remoting.impl.invm.InVMConnectorFactory - - - org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory - - - - - org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory - - - - - - - - org.apache.activemq.core.remoting.impl.invm.InVMAcceptorFactory - - - org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory - - - - - - - - - 1 - true - 1000 - - invm-connector - server0-connector - netty-connector - - - - - - invm-connector - - - - - - - - - -
jms
- netty-connector - 500 - true - true - 1 - - server0-connector - -
-
- - - - - - - - - - - - - - - - -
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server1/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server1/activemq-users.xml b/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server1/activemq-users.xml deleted file mode 100644 index ae30546..0000000 --- a/examples/jms/ha-policy-autobackup/src/main/resources/hornetq/server1/activemq-users.xml +++ /dev/null @@ -1,7 +0,0 @@ - - - - - - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/http-transport/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/http-transport/pom.xml b/examples/jms/http-transport/pom.xml index 24a5f54..9bc6c63 100644 --- a/examples/jms/http-transport/pom.xml +++ b/examples/jms/http-transport/pom.xml @@ -102,7 +102,7 @@ false - ${basedir}/target/classes/activemq/server0 + ${basedir}/target/classes/activemq/server0 build.directory http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/http-transport/src/main/java/org/apache/activemq/jms/example/HttpTransportExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/http-transport/src/main/java/org/apache/activemq/jms/example/HttpTransportExample.java b/examples/jms/http-transport/src/main/java/org/apache/activemq/jms/example/HttpTransportExample.java index efba974..914c017 100644 --- a/examples/jms/http-transport/src/main/java/org/apache/activemq/jms/example/HttpTransportExample.java +++ b/examples/jms/http-transport/src/main/java/org/apache/activemq/jms/example/HttpTransportExample.java @@ -47,7 +47,7 @@ public class HttpTransportExample extends ActiveMQExample try { // Step 1. Create an initial context to perform the JNDI lookup. - initialContext = getContext(0); + initialContext = new InitialContext(); // Step 2. Perfom a lookup on the queue Queue queue = (Queue)initialContext.lookup("queue/exampleQueue"); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/http-transport/src/main/resources/activemq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/http-transport/src/main/resources/activemq/server0/activemq-configuration.xml b/examples/jms/http-transport/src/main/resources/activemq/server0/activemq-configuration.xml new file mode 100644 index 0000000..5bc2739 --- /dev/null +++ b/examples/jms/http-transport/src/main/resources/activemq/server0/activemq-configuration.xml @@ -0,0 +1,36 @@ + + + ${build.directory}/server0/data/messaging/bindings + + ${build.directory}/server0/data/messaging/journal + + ${build.directory}/server0/data/messaging/largemessages + + ${build.directory}/server0/data/messaging/paging + + + + + + org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory + + + + + + + + + + + + + + + + + + + http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/http-transport/src/main/resources/activemq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/http-transport/src/main/resources/activemq/server0/activemq-jms.xml b/examples/jms/http-transport/src/main/resources/activemq/server0/activemq-jms.xml new file mode 100644 index 0000000..847659f --- /dev/null +++ b/examples/jms/http-transport/src/main/resources/activemq/server0/activemq-jms.xml @@ -0,0 +1,8 @@ + + + + + + \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/http-transport/src/main/resources/activemq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/http-transport/src/main/resources/activemq/server0/activemq-users.xml b/examples/jms/http-transport/src/main/resources/activemq/server0/activemq-users.xml new file mode 100644 index 0000000..ae30546 --- /dev/null +++ b/examples/jms/http-transport/src/main/resources/activemq/server0/activemq-users.xml @@ -0,0 +1,7 @@ + + + + + + \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/http-transport/src/main/resources/hornetq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/http-transport/src/main/resources/hornetq/server0/activemq-configuration.xml b/examples/jms/http-transport/src/main/resources/hornetq/server0/activemq-configuration.xml deleted file mode 100644 index 61eab50..0000000 --- a/examples/jms/http-transport/src/main/resources/hornetq/server0/activemq-configuration.xml +++ /dev/null @@ -1,46 +0,0 @@ - - - ${build.directory}/server0/data/messaging/bindings - - ${build.directory}/server0/data/messaging/journal - - ${build.directory}/server0/data/messaging/largemessages - - ${build.directory}/server0/data/messaging/paging - - - - - - org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory - - - - - - - - - - org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory - - - - - - - - - - - - - - - - - - - http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/http-transport/src/main/resources/hornetq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/http-transport/src/main/resources/hornetq/server0/activemq-jms.xml b/examples/jms/http-transport/src/main/resources/hornetq/server0/activemq-jms.xml deleted file mode 100644 index 847659f..0000000 --- a/examples/jms/http-transport/src/main/resources/hornetq/server0/activemq-jms.xml +++ /dev/null @@ -1,8 +0,0 @@ - - - - - - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/http-transport/src/main/resources/hornetq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/http-transport/src/main/resources/hornetq/server0/activemq-users.xml b/examples/jms/http-transport/src/main/resources/hornetq/server0/activemq-users.xml deleted file mode 100644 index ae30546..0000000 --- a/examples/jms/http-transport/src/main/resources/hornetq/server0/activemq-users.xml +++ /dev/null @@ -1,7 +0,0 @@ - - - - - - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/http-transport/src/main/resources/jndi.properties ---------------------------------------------------------------------- diff --git a/examples/jms/http-transport/src/main/resources/jndi.properties b/examples/jms/http-transport/src/main/resources/jndi.properties new file mode 100644 index 0000000..fee3aac --- /dev/null +++ b/examples/jms/http-transport/src/main/resources/jndi.properties @@ -0,0 +1,3 @@ +java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory +java.naming.provider.url=tcp://localhost:8080?http-enabled=true +queue.queue/exampleQueue=exampleQueue http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/instantiate-connection-factory/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/instantiate-connection-factory/pom.xml b/examples/jms/instantiate-connection-factory/pom.xml index 4b60d79..bb9f409 100644 --- a/examples/jms/instantiate-connection-factory/pom.xml +++ b/examples/jms/instantiate-connection-factory/pom.xml @@ -112,7 +112,7 @@ false - ${basedir}/target/classes/activemq/server0 + ${basedir}/target/classes/activemq/server0 http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/instantiate-connection-factory/src/main/resources/activemq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/instantiate-connection-factory/src/main/resources/activemq/server0/activemq-configuration.xml b/examples/jms/instantiate-connection-factory/src/main/resources/activemq/server0/activemq-configuration.xml new file mode 100644 index 0000000..afaec1c --- /dev/null +++ b/examples/jms/instantiate-connection-factory/src/main/resources/activemq/server0/activemq-configuration.xml @@ -0,0 +1,35 @@ + + + ${build.directory}/server0/data/messaging/bindings + + ${build.directory}/server0/data/messaging/journal + + ${build.directory}/server0/data/messaging/largemessages + + ${build.directory}/server0/data/messaging/paging + + + + + org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory + + + + + + + + + + + + + + + + + + + http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/instantiate-connection-factory/src/main/resources/activemq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/instantiate-connection-factory/src/main/resources/activemq/server0/activemq-jms.xml b/examples/jms/instantiate-connection-factory/src/main/resources/activemq/server0/activemq-jms.xml new file mode 100644 index 0000000..9dd800b --- /dev/null +++ b/examples/jms/instantiate-connection-factory/src/main/resources/activemq/server0/activemq-jms.xml @@ -0,0 +1,8 @@ + + + + + + http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/instantiate-connection-factory/src/main/resources/activemq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/instantiate-connection-factory/src/main/resources/activemq/server0/activemq-users.xml b/examples/jms/instantiate-connection-factory/src/main/resources/activemq/server0/activemq-users.xml new file mode 100644 index 0000000..ae30546 --- /dev/null +++ b/examples/jms/instantiate-connection-factory/src/main/resources/activemq/server0/activemq-users.xml @@ -0,0 +1,7 @@ + + + + + + \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/instantiate-connection-factory/src/main/resources/hornetq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/instantiate-connection-factory/src/main/resources/hornetq/server0/activemq-configuration.xml b/examples/jms/instantiate-connection-factory/src/main/resources/hornetq/server0/activemq-configuration.xml deleted file mode 100644 index 1cb9416..0000000 --- a/examples/jms/instantiate-connection-factory/src/main/resources/hornetq/server0/activemq-configuration.xml +++ /dev/null @@ -1,45 +0,0 @@ - - - ${build.directory}/server0/data/messaging/bindings - - ${build.directory}/server0/data/messaging/journal - - ${build.directory}/server0/data/messaging/largemessages - - ${build.directory}/server0/data/messaging/paging - - - - - - - org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory - - - - - - - - org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory - - - - - - - - - - - - - - - - - - - http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/instantiate-connection-factory/src/main/resources/hornetq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/instantiate-connection-factory/src/main/resources/hornetq/server0/activemq-jms.xml b/examples/jms/instantiate-connection-factory/src/main/resources/hornetq/server0/activemq-jms.xml deleted file mode 100644 index d05e31e..0000000 --- a/examples/jms/instantiate-connection-factory/src/main/resources/hornetq/server0/activemq-jms.xml +++ /dev/null @@ -1,10 +0,0 @@ - - - - - - - - http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/instantiate-connection-factory/src/main/resources/hornetq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/instantiate-connection-factory/src/main/resources/hornetq/server0/activemq-users.xml b/examples/jms/instantiate-connection-factory/src/main/resources/hornetq/server0/activemq-users.xml deleted file mode 100644 index ae30546..0000000 --- a/examples/jms/instantiate-connection-factory/src/main/resources/hornetq/server0/activemq-users.xml +++ /dev/null @@ -1,7 +0,0 @@ - - - - - - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/interceptor/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/interceptor/pom.xml b/examples/jms/interceptor/pom.xml index 34dff8c..5ff60f5 100644 --- a/examples/jms/interceptor/pom.xml +++ b/examples/jms/interceptor/pom.xml @@ -107,7 +107,7 @@ false - ${basedir}/target/classes/activemq/server0 + ${basedir}/target/classes/activemq/server0 http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/interceptor/src/main/java/org/apache/activemq/jms/example/InterceptorExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/interceptor/src/main/java/org/apache/activemq/jms/example/InterceptorExample.java b/examples/jms/interceptor/src/main/java/org/apache/activemq/jms/example/InterceptorExample.java index e2b2b40..70f0231 100644 --- a/examples/jms/interceptor/src/main/java/org/apache/activemq/jms/example/InterceptorExample.java +++ b/examples/jms/interceptor/src/main/java/org/apache/activemq/jms/example/InterceptorExample.java @@ -47,7 +47,7 @@ public class InterceptorExample extends ActiveMQExample try { // Step 1. Create an initial context to perform the JNDI lookup. - initialContext = getContext(0); + initialContext = new InitialContext(); // Step 2. Perform a lookup on the queue Queue queue = (Queue)initialContext.lookup("queue/exampleQueue"); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/interceptor/src/main/resources/activemq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/interceptor/src/main/resources/activemq/server0/activemq-configuration.xml b/examples/jms/interceptor/src/main/resources/activemq/server0/activemq-configuration.xml new file mode 100644 index 0000000..e9dabca --- /dev/null +++ b/examples/jms/interceptor/src/main/resources/activemq/server0/activemq-configuration.xml @@ -0,0 +1,39 @@ + + + ${build.directory}/server0/data/messaging/bindings + + ${build.directory}/server0/data/messaging/journal + + ${build.directory}/server0/data/messaging/largemessages + + ${build.directory}/server0/data/messaging/paging + + + + org.apache.activemq.jms.example.SimpleInterceptor + + + + + + org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory + + + + + + + + + + + + + + + + + + http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/interceptor/src/main/resources/activemq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/interceptor/src/main/resources/activemq/server0/activemq-jms.xml b/examples/jms/interceptor/src/main/resources/activemq/server0/activemq-jms.xml new file mode 100644 index 0000000..0d5c953 --- /dev/null +++ b/examples/jms/interceptor/src/main/resources/activemq/server0/activemq-jms.xml @@ -0,0 +1,8 @@ + + + + + + http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/interceptor/src/main/resources/activemq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/interceptor/src/main/resources/activemq/server0/activemq-users.xml b/examples/jms/interceptor/src/main/resources/activemq/server0/activemq-users.xml new file mode 100644 index 0000000..ae30546 --- /dev/null +++ b/examples/jms/interceptor/src/main/resources/activemq/server0/activemq-users.xml @@ -0,0 +1,7 @@ + + + + + + \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/interceptor/src/main/resources/hornetq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/interceptor/src/main/resources/hornetq/server0/activemq-configuration.xml b/examples/jms/interceptor/src/main/resources/hornetq/server0/activemq-configuration.xml deleted file mode 100644 index 2433360..0000000 --- a/examples/jms/interceptor/src/main/resources/hornetq/server0/activemq-configuration.xml +++ /dev/null @@ -1,47 +0,0 @@ - - - ${build.directory}/server0/data/messaging/bindings - - ${build.directory}/server0/data/messaging/journal - - ${build.directory}/server0/data/messaging/largemessages - - ${build.directory}/server0/data/messaging/paging - - - - org.apache.activemq.jms.example.SimpleInterceptor - - - - - - - org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory - - - - - - - org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory - - - - - - - - - - - - - - - - - - http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/interceptor/src/main/resources/hornetq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/interceptor/src/main/resources/hornetq/server0/activemq-jms.xml b/examples/jms/interceptor/src/main/resources/hornetq/server0/activemq-jms.xml deleted file mode 100644 index 0d5c953..0000000 --- a/examples/jms/interceptor/src/main/resources/hornetq/server0/activemq-jms.xml +++ /dev/null @@ -1,8 +0,0 @@ - - - - - - http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/interceptor/src/main/resources/hornetq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/interceptor/src/main/resources/hornetq/server0/activemq-users.xml b/examples/jms/interceptor/src/main/resources/hornetq/server0/activemq-users.xml deleted file mode 100644 index ae30546..0000000 --- a/examples/jms/interceptor/src/main/resources/hornetq/server0/activemq-users.xml +++ /dev/null @@ -1,7 +0,0 @@ - - - - - - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/interceptor/src/main/resources/jndi.properties ---------------------------------------------------------------------- diff --git a/examples/jms/interceptor/src/main/resources/jndi.properties b/examples/jms/interceptor/src/main/resources/jndi.properties new file mode 100644 index 0000000..d9b5c6a --- /dev/null +++ b/examples/jms/interceptor/src/main/resources/jndi.properties @@ -0,0 +1,3 @@ +java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory +java.naming.provider.url=tcp://localhost:5445 +queue.queue/exampleQueue=exampleQueue \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jaas/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/jaas/pom.xml b/examples/jms/jaas/pom.xml index 1ce345b..a6ba21c 100644 --- a/examples/jms/jaas/pom.xml +++ b/examples/jms/jaas/pom.xml @@ -39,7 +39,6 @@ org.apache.activemq activemq-maven-plugin - 1.1.0 start @@ -125,7 +124,7 @@ false - ${basedir}/target/classes/activemq/server0 + ${basedir}/target/classes/activemq/server0 http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jaas/src/main/java/org/apache/activemq/jms/example/JAASExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/jaas/src/main/java/org/apache/activemq/jms/example/JAASExample.java b/examples/jms/jaas/src/main/java/org/apache/activemq/jms/example/JAASExample.java index 7813924..be797d1 100644 --- a/examples/jms/jaas/src/main/java/org/apache/activemq/jms/example/JAASExample.java +++ b/examples/jms/jaas/src/main/java/org/apache/activemq/jms/example/JAASExample.java @@ -48,7 +48,7 @@ public class JAASExample extends ActiveMQExample try { // Step 1. Create an initial context to perform the JNDI lookup. - initialContext = getContext(0); + initialContext = new InitialContext(); // Step 2. Perfom a lookup on the queue Queue queue = (Queue)initialContext.lookup("queue/exampleQueue"); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jaas/src/main/resources/activemq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/jaas/src/main/resources/activemq/server0/activemq-configuration.xml b/examples/jms/jaas/src/main/resources/activemq/server0/activemq-configuration.xml new file mode 100644 index 0000000..52d9570 --- /dev/null +++ b/examples/jms/jaas/src/main/resources/activemq/server0/activemq-configuration.xml @@ -0,0 +1,34 @@ + + + ${build.directory}/server0/data/messaging/bindings + + ${build.directory}/server0/data/messaging/journal + + ${build.directory}/server0/data/messaging/largemessages + + ${build.directory}/server0/data/messaging/paging + + + + + org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory + + + + + + + + + + + + + + + + + + http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jaas/src/main/resources/activemq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/jaas/src/main/resources/activemq/server0/activemq-jms.xml b/examples/jms/jaas/src/main/resources/activemq/server0/activemq-jms.xml new file mode 100644 index 0000000..0d5c953 --- /dev/null +++ b/examples/jms/jaas/src/main/resources/activemq/server0/activemq-jms.xml @@ -0,0 +1,8 @@ + + + + + + http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jaas/src/main/resources/hornetq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/jaas/src/main/resources/hornetq/server0/activemq-configuration.xml b/examples/jms/jaas/src/main/resources/hornetq/server0/activemq-configuration.xml deleted file mode 100644 index e0acd1d..0000000 --- a/examples/jms/jaas/src/main/resources/hornetq/server0/activemq-configuration.xml +++ /dev/null @@ -1,43 +0,0 @@ - - - ${build.directory}/server0/data/messaging/bindings - - ${build.directory}/server0/data/messaging/journal - - ${build.directory}/server0/data/messaging/largemessages - - ${build.directory}/server0/data/messaging/paging - - - - - - - org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory - - - - - - - org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory - - - - - - - - - - - - - - - - - - http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jaas/src/main/resources/hornetq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/jaas/src/main/resources/hornetq/server0/activemq-jms.xml b/examples/jms/jaas/src/main/resources/hornetq/server0/activemq-jms.xml deleted file mode 100644 index 0d5c953..0000000 --- a/examples/jms/jaas/src/main/resources/hornetq/server0/activemq-jms.xml +++ /dev/null @@ -1,8 +0,0 @@ - - - - - - http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jaas/src/main/resources/jndi.properties ---------------------------------------------------------------------- diff --git a/examples/jms/jaas/src/main/resources/jndi.properties b/examples/jms/jaas/src/main/resources/jndi.properties new file mode 100644 index 0000000..d9b5c6a --- /dev/null +++ b/examples/jms/jaas/src/main/resources/jndi.properties @@ -0,0 +1,3 @@ +java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory +java.naming.provider.url=tcp://localhost:5445 +queue.queue/exampleQueue=exampleQueue \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jms-auto-closeable/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/jms-auto-closeable/pom.xml b/examples/jms/jms-auto-closeable/pom.xml index d0c49da..084ddf9 100644 --- a/examples/jms/jms-auto-closeable/pom.xml +++ b/examples/jms/jms-auto-closeable/pom.xml @@ -51,9 +51,6 @@ org.apache.activemq.jms.example.JMSAutoCloseableExample - - tcp://localhost:5445 - @@ -102,7 +99,7 @@ false - ${basedir}/target/classes/activemq/server0 + ${basedir}/target/classes/activemq/server0 http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jms-auto-closeable/src/main/java/org/apache/activemq/jms/example/JMSAutoCloseableExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/jms-auto-closeable/src/main/java/org/apache/activemq/jms/example/JMSAutoCloseableExample.java b/examples/jms/jms-auto-closeable/src/main/java/org/apache/activemq/jms/example/JMSAutoCloseableExample.java index d832771..646fdeb 100644 --- a/examples/jms/jms-auto-closeable/src/main/java/org/apache/activemq/jms/example/JMSAutoCloseableExample.java +++ b/examples/jms/jms-auto-closeable/src/main/java/org/apache/activemq/jms/example/JMSAutoCloseableExample.java @@ -40,7 +40,7 @@ public class JMSAutoCloseableExample extends ActiveMQExample try { // Step 1. Create an initial context to perform the JNDI lookup. - initialContext = getContext(0); + initialContext = new InitialContext(); // Step 2. Perfom a lookup on the queue Queue queue = (Queue)initialContext.lookup("queue/exampleQueue"); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jms-auto-closeable/src/main/resources/activemq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/jms-auto-closeable/src/main/resources/activemq/server0/activemq-configuration.xml b/examples/jms/jms-auto-closeable/src/main/resources/activemq/server0/activemq-configuration.xml new file mode 100644 index 0000000..0d65f69 --- /dev/null +++ b/examples/jms/jms-auto-closeable/src/main/resources/activemq/server0/activemq-configuration.xml @@ -0,0 +1,33 @@ + + + ${build.directory}/server0/data/messaging/bindings + + ${build.directory}/server0/data/messaging/journal + + ${build.directory}/server0/data/messaging/largemessages + + ${build.directory}/server0/data/messaging/paging + + + + + org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory + + + + + + + + + + + + + + + + + http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jms-auto-closeable/src/main/resources/activemq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/jms-auto-closeable/src/main/resources/activemq/server0/activemq-jms.xml b/examples/jms/jms-auto-closeable/src/main/resources/activemq/server0/activemq-jms.xml new file mode 100644 index 0000000..0d5c953 --- /dev/null +++ b/examples/jms/jms-auto-closeable/src/main/resources/activemq/server0/activemq-jms.xml @@ -0,0 +1,8 @@ + + + + + + http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jms-auto-closeable/src/main/resources/activemq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/jms-auto-closeable/src/main/resources/activemq/server0/activemq-users.xml b/examples/jms/jms-auto-closeable/src/main/resources/activemq/server0/activemq-users.xml new file mode 100644 index 0000000..ae30546 --- /dev/null +++ b/examples/jms/jms-auto-closeable/src/main/resources/activemq/server0/activemq-users.xml @@ -0,0 +1,7 @@ + + + + + + \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jms-auto-closeable/src/main/resources/hornetq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/jms-auto-closeable/src/main/resources/hornetq/server0/activemq-configuration.xml b/examples/jms/jms-auto-closeable/src/main/resources/hornetq/server0/activemq-configuration.xml deleted file mode 100644 index 9ff5b8a..0000000 --- a/examples/jms/jms-auto-closeable/src/main/resources/hornetq/server0/activemq-configuration.xml +++ /dev/null @@ -1,42 +0,0 @@ - - - ${build.directory}/server0/data/messaging/bindings - - ${build.directory}/server0/data/messaging/journal - - ${build.directory}/server0/data/messaging/largemessages - - ${build.directory}/server0/data/messaging/paging - - - - - - - org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory - - - - - - - org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory - - - - - - - - - - - - - - - - - http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jms-auto-closeable/src/main/resources/hornetq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/jms-auto-closeable/src/main/resources/hornetq/server0/activemq-jms.xml b/examples/jms/jms-auto-closeable/src/main/resources/hornetq/server0/activemq-jms.xml deleted file mode 100644 index 0d5c953..0000000 --- a/examples/jms/jms-auto-closeable/src/main/resources/hornetq/server0/activemq-jms.xml +++ /dev/null @@ -1,8 +0,0 @@ - - - - - - http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jms-auto-closeable/src/main/resources/hornetq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/jms-auto-closeable/src/main/resources/hornetq/server0/activemq-users.xml b/examples/jms/jms-auto-closeable/src/main/resources/hornetq/server0/activemq-users.xml deleted file mode 100644 index ae30546..0000000 --- a/examples/jms/jms-auto-closeable/src/main/resources/hornetq/server0/activemq-users.xml +++ /dev/null @@ -1,7 +0,0 @@ - - - - - - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jms-auto-closeable/src/main/resources/jndi.properties ---------------------------------------------------------------------- diff --git a/examples/jms/jms-auto-closeable/src/main/resources/jndi.properties b/examples/jms/jms-auto-closeable/src/main/resources/jndi.properties new file mode 100644 index 0000000..d9b5c6a --- /dev/null +++ b/examples/jms/jms-auto-closeable/src/main/resources/jndi.properties @@ -0,0 +1,3 @@ +java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory +java.naming.provider.url=tcp://localhost:5445 +queue.queue/exampleQueue=exampleQueue \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jms-bridge/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/jms-bridge/pom.xml b/examples/jms/jms-bridge/pom.xml index f014b5b..67ca1ea 100644 --- a/examples/jms/jms-bridge/pom.xml +++ b/examples/jms/jms-bridge/pom.xml @@ -45,7 +45,7 @@ start - ${basedir}/target/classes/activemq/server0 + ${basedir}/target/classes/activemq/server0 @@ -54,9 +54,7 @@ start - 1199 - 1198 - ${basedir}/target/classes/activemq/server1 + ${basedir}/target/classes/activemq/server1 true @@ -85,7 +83,7 @@ stop - ${basedir}/target/classes/activemq/server0 + ${basedir}/target/classes/activemq/server0 @@ -94,7 +92,7 @@ stop - ${basedir}/target/classes/activemq/server1 + ${basedir}/target/classes/activemq/server1 http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/jms-bridge/src/main/java/org/apache/activemq/jms/example/JMSBridgeExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/jms-bridge/src/main/java/org/apache/activemq/jms/example/JMSBridgeExample.java b/examples/jms/jms-bridge/src/main/java/org/apache/activemq/jms/example/JMSBridgeExample.java index 0126251..f6ff686 100644 --- a/examples/jms/jms-bridge/src/main/java/org/apache/activemq/jms/example/JMSBridgeExample.java +++ b/examples/jms/jms-bridge/src/main/java/org/apache/activemq/jms/example/JMSBridgeExample.java @@ -66,8 +66,8 @@ public class JMSBridgeExample // Step 2. Create and start a JMS Bridge // Note, the Bridge needs a transaction manager, in this instance we will use the JBoss TM JMSBridge jmsBridge = new JMSBridgeImpl( - new JNDIConnectionFactoryFactory(sourceJndiParams, "source/ConnectionFactory"), - new JNDIConnectionFactoryFactory(targetJndiParams, "target/ConnectionFactory"), + new JNDIConnectionFactoryFactory(sourceJndiParams, "ConnectionFactory"), + new JNDIConnectionFactoryFactory(targetJndiParams, "ConnectionFactory"), new JNDIDestinationFactory(sourceJndiParams, "source/topic"), new JNDIDestinationFactory(targetJndiParams, "target/queue"), null, @@ -91,8 +91,8 @@ public class JMSBridgeExample { jmsBridge.start(); // Step 3. Lookup the *source* JMS resources - ConnectionFactory sourceConnectionFactory = (ConnectionFactory)sourceContext.lookup("/client/ConnectionFactory"); - Topic sourceTopic = (Topic)sourceContext.lookup("/source/topic"); + ConnectionFactory sourceConnectionFactory = (ConnectionFactory)sourceContext.lookup("ConnectionFactory"); + Topic sourceTopic = (Topic)sourceContext.lookup("source/topic"); // Step 4. Create a connection, a session and a message producer for the *source* topic sourceConnection = sourceConnectionFactory.createConnection(); @@ -111,7 +111,7 @@ public class JMSBridgeExample sourceConnection.close(); // Step 7. Lookup the *target* JMS resources - ConnectionFactory targetConnectionFactory = (ConnectionFactory)targetContext.lookup("client/ConnectionFactory"); + ConnectionFactory targetConnectionFactory = (ConnectionFactory)targetContext.lookup("ConnectionFactory"); Queue targetQueue = (Queue)targetContext.lookup("target/queue"); // Step 8. Create a connection, a session and a message consumer for the *target* queue @@ -169,6 +169,8 @@ public class JMSBridgeExample Hashtable jndiProps = new Hashtable(); jndiProps.put("java.naming.provider.url", server); jndiProps.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory"); + jndiProps.put("queue.target/queue", "target"); + jndiProps.put("topic.source/topic", "topic"); return jndiProps; } }