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 78DF310957 for ; Wed, 10 Dec 2014 16:11:29 +0000 (UTC) Received: (qmail 13626 invoked by uid 500); 10 Dec 2014 16:11:29 -0000 Delivered-To: apmail-activemq-commits-archive@activemq.apache.org Received: (qmail 13439 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 12703 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 89910A23D5E; 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:46 -0000 Message-Id: In-Reply-To: <34f402ddf8314dd6a70969b26485f39b@git.apache.org> References: <34f402ddf8314dd6a70969b26485f39b@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [20/37] activemq-6 git commit: ACTIVEMQ6-51 Example server bootstrapping http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/send-acknowledgements/src/main/resources/hornetq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/send-acknowledgements/src/main/resources/hornetq/server0/activemq-users.xml b/examples/jms/send-acknowledgements/src/main/resources/hornetq/server0/activemq-users.xml deleted file mode 100644 index ae30546..0000000 --- a/examples/jms/send-acknowledgements/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/send-acknowledgements/src/main/resources/jndi.properties ---------------------------------------------------------------------- diff --git a/examples/jms/send-acknowledgements/src/main/resources/jndi.properties b/examples/jms/send-acknowledgements/src/main/resources/jndi.properties new file mode 100644 index 0000000..5361f83 --- /dev/null +++ b/examples/jms/send-acknowledgements/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 +connection.ConnectionFactory.confirmationWindowSize=1048576 +queue.queue/exampleQueue=exampleQueue \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/spring-integration/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/spring-integration/pom.xml b/examples/jms/spring-integration/pom.xml index 22db0f2..c57dc67 100644 --- a/examples/jms/spring-integration/pom.xml +++ b/examples/jms/spring-integration/pom.xml @@ -46,9 +46,6 @@ org.apache.activemq.jms.example.SpringExample - - tcp://localhost:5445 - @@ -91,7 +88,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/spring-integration/src/main/resources/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/spring-integration/src/main/resources/activemq-configuration.xml b/examples/jms/spring-integration/src/main/resources/activemq-configuration.xml index 7e86c38..2db2db3 100644 --- a/examples/jms/spring-integration/src/main/resources/activemq-configuration.xml +++ b/examples/jms/spring-integration/src/main/resources/activemq-configuration.xml @@ -3,13 +3,6 @@ xsi:schemaLocation="urn:activemq /schema/activemq-configuration.xsd"> false - - - - - org.apache.activemq.core.remoting.impl.invm.InVMConnectorFactory - - http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/spring-integration/src/main/resources/spring-jms-beans.xml ---------------------------------------------------------------------- diff --git a/examples/jms/spring-integration/src/main/resources/spring-jms-beans.xml b/examples/jms/spring-integration/src/main/resources/spring-jms-beans.xml index c9eccea..9378efb 100644 --- a/examples/jms/spring-integration/src/main/resources/spring-jms-beans.xml +++ b/examples/jms/spring-integration/src/main/resources/spring-jms-beans.xml @@ -4,22 +4,34 @@ xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd"> - + - - - - - - + + + + + + + + + + + + - - - - - - + + + + + + + + + + + \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ssl-enabled/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ssl-enabled/pom.xml b/examples/jms/ssl-enabled/pom.xml index 8fe2534..9220b13 100644 --- a/examples/jms/ssl-enabled/pom.xml +++ b/examples/jms/ssl-enabled/pom.xml @@ -51,9 +51,6 @@ org.apache.activemq.jms.example.SSLExample - - 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/ssl-enabled/src/main/java/org/apache/activemq/jms/example/SSLExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/ssl-enabled/src/main/java/org/apache/activemq/jms/example/SSLExample.java b/examples/jms/ssl-enabled/src/main/java/org/apache/activemq/jms/example/SSLExample.java index e025afd..7483506 100644 --- a/examples/jms/ssl-enabled/src/main/java/org/apache/activemq/jms/example/SSLExample.java +++ b/examples/jms/ssl-enabled/src/main/java/org/apache/activemq/jms/example/SSLExample.java @@ -47,7 +47,7 @@ public class SSLExample 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/ssl-enabled/src/main/resources/activemq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ssl-enabled/src/main/resources/activemq/server0/activemq-configuration.xml b/examples/jms/ssl-enabled/src/main/resources/activemq/server0/activemq-configuration.xml new file mode 100644 index 0000000..ce77b71 --- /dev/null +++ b/examples/jms/ssl-enabled/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.core.remoting.impl.netty.NettyAcceptorFactory + + + + + + + + + + + + + + + + + + + + + + + http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ssl-enabled/src/main/resources/activemq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ssl-enabled/src/main/resources/activemq/server0/activemq-jms.xml b/examples/jms/ssl-enabled/src/main/resources/activemq/server0/activemq-jms.xml new file mode 100644 index 0000000..0d5c953 --- /dev/null +++ b/examples/jms/ssl-enabled/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/ssl-enabled/src/main/resources/activemq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ssl-enabled/src/main/resources/activemq/server0/activemq-users.xml b/examples/jms/ssl-enabled/src/main/resources/activemq/server0/activemq-users.xml new file mode 100644 index 0000000..ae30546 --- /dev/null +++ b/examples/jms/ssl-enabled/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/ssl-enabled/src/main/resources/activemq/server0/activemq.example.keystore ---------------------------------------------------------------------- diff --git a/examples/jms/ssl-enabled/src/main/resources/activemq/server0/activemq.example.keystore b/examples/jms/ssl-enabled/src/main/resources/activemq/server0/activemq.example.keystore new file mode 100644 index 0000000..50de681 Binary files /dev/null and b/examples/jms/ssl-enabled/src/main/resources/activemq/server0/activemq.example.keystore differ http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ssl-enabled/src/main/resources/activemq/server0/activemq.example.truststore ---------------------------------------------------------------------- diff --git a/examples/jms/ssl-enabled/src/main/resources/activemq/server0/activemq.example.truststore b/examples/jms/ssl-enabled/src/main/resources/activemq/server0/activemq.example.truststore new file mode 100644 index 0000000..129391a Binary files /dev/null and b/examples/jms/ssl-enabled/src/main/resources/activemq/server0/activemq.example.truststore differ http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ssl-enabled/src/main/resources/hornetq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ssl-enabled/src/main/resources/hornetq/server0/activemq-configuration.xml b/examples/jms/ssl-enabled/src/main/resources/hornetq/server0/activemq-configuration.xml deleted file mode 100644 index 8bba089..0000000 --- a/examples/jms/ssl-enabled/src/main/resources/hornetq/server0/activemq-configuration.xml +++ /dev/null @@ -1,53 +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/ssl-enabled/src/main/resources/hornetq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ssl-enabled/src/main/resources/hornetq/server0/activemq-jms.xml b/examples/jms/ssl-enabled/src/main/resources/hornetq/server0/activemq-jms.xml deleted file mode 100644 index 0d5c953..0000000 --- a/examples/jms/ssl-enabled/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/ssl-enabled/src/main/resources/hornetq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/ssl-enabled/src/main/resources/hornetq/server0/activemq-users.xml b/examples/jms/ssl-enabled/src/main/resources/hornetq/server0/activemq-users.xml deleted file mode 100644 index ae30546..0000000 --- a/examples/jms/ssl-enabled/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/ssl-enabled/src/main/resources/hornetq/server0/hornetq.example.keystore ---------------------------------------------------------------------- diff --git a/examples/jms/ssl-enabled/src/main/resources/hornetq/server0/hornetq.example.keystore b/examples/jms/ssl-enabled/src/main/resources/hornetq/server0/hornetq.example.keystore deleted file mode 100644 index 8ca2ea4..0000000 Binary files a/examples/jms/ssl-enabled/src/main/resources/hornetq/server0/hornetq.example.keystore and /dev/null differ http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ssl-enabled/src/main/resources/hornetq/server0/hornetq.example.truststore ---------------------------------------------------------------------- diff --git a/examples/jms/ssl-enabled/src/main/resources/hornetq/server0/hornetq.example.truststore b/examples/jms/ssl-enabled/src/main/resources/hornetq/server0/hornetq.example.truststore deleted file mode 100644 index 49dd088..0000000 Binary files a/examples/jms/ssl-enabled/src/main/resources/hornetq/server0/hornetq.example.truststore and /dev/null differ http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/ssl-enabled/src/main/resources/jndi.properties ---------------------------------------------------------------------- diff --git a/examples/jms/ssl-enabled/src/main/resources/jndi.properties b/examples/jms/ssl-enabled/src/main/resources/jndi.properties new file mode 100644 index 0000000..948b4bd --- /dev/null +++ b/examples/jms/ssl-enabled/src/main/resources/jndi.properties @@ -0,0 +1,3 @@ +java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory +java.naming.provider.url=tcp://localhost:5500?ssl-enabled=true&trust-store-path=activemq/server0/activemq.example.truststore&trust-store-password=activemqexample +queue.queue/exampleQueue=exampleQueue \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/static-selector-jms/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector-jms/pom.xml b/examples/jms/static-selector-jms/pom.xml index ba5cd8a..4bac000 100644 --- a/examples/jms/static-selector-jms/pom.xml +++ b/examples/jms/static-selector-jms/pom.xml @@ -102,7 +102,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/static-selector-jms/src/main/java/org/apache/activemq/jms/example/StaticSelectorJMSExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector-jms/src/main/java/org/apache/activemq/jms/example/StaticSelectorJMSExample.java b/examples/jms/static-selector-jms/src/main/java/org/apache/activemq/jms/example/StaticSelectorJMSExample.java index 7b976e4..267384d 100644 --- a/examples/jms/static-selector-jms/src/main/java/org/apache/activemq/jms/example/StaticSelectorJMSExample.java +++ b/examples/jms/static-selector-jms/src/main/java/org/apache/activemq/jms/example/StaticSelectorJMSExample.java @@ -52,7 +52,7 @@ public class StaticSelectorJMSExample extends ActiveMQExample try { // Step 1. Create an initial context to perform the JNDI lookup. - initialContext = getContext(0); + initialContext = new InitialContext(); // Step 2. look-up the JMS queue object from JNDI, this is the queue that has filter configured with it. Queue queue = (Queue)initialContext.lookup("queue/exampleQueue"); @@ -68,9 +68,10 @@ public class StaticSelectorJMSExample extends ActiveMQExample // Step 6. Create a JMS Session Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + Session producerSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); // Step 7. Create a JMS Message Producer - MessageProducer producer = session.createProducer(queue); + MessageProducer producer = producerSession.createProducer(queue); // Step 8. Create a JMS Message Consumer that receives 'red' messages MessageConsumer redConsumer = session.createConsumer(queue); @@ -138,7 +139,7 @@ public class StaticSelectorJMSExample extends ActiveMQExample textMessage.getText() + "] with color property: " + colorProp); - if (!colorProp.equals(name)) + if (colorProp != null && !colorProp.equals(name)) { result = false; } http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/static-selector-jms/src/main/resources/activemq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector-jms/src/main/resources/activemq/server0/activemq-configuration.xml b/examples/jms/static-selector-jms/src/main/resources/activemq/server0/activemq-configuration.xml new file mode 100644 index 0000000..5d9a671 --- /dev/null +++ b/examples/jms/static-selector-jms/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/static-selector-jms/src/main/resources/activemq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector-jms/src/main/resources/activemq/server0/activemq-jms.xml b/examples/jms/static-selector-jms/src/main/resources/activemq/server0/activemq-jms.xml new file mode 100644 index 0000000..c618cfb --- /dev/null +++ b/examples/jms/static-selector-jms/src/main/resources/activemq/server0/activemq-jms.xml @@ -0,0 +1,10 @@ + + + + + + + + \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/static-selector-jms/src/main/resources/activemq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector-jms/src/main/resources/activemq/server0/activemq-users.xml b/examples/jms/static-selector-jms/src/main/resources/activemq/server0/activemq-users.xml new file mode 100644 index 0000000..ae30546 --- /dev/null +++ b/examples/jms/static-selector-jms/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/static-selector-jms/src/main/resources/hornetq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector-jms/src/main/resources/hornetq/server0/activemq-configuration.xml b/examples/jms/static-selector-jms/src/main/resources/hornetq/server0/activemq-configuration.xml deleted file mode 100644 index d098c40..0000000 --- a/examples/jms/static-selector-jms/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/static-selector-jms/src/main/resources/hornetq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector-jms/src/main/resources/hornetq/server0/activemq-jms.xml b/examples/jms/static-selector-jms/src/main/resources/hornetq/server0/activemq-jms.xml deleted file mode 100644 index c618cfb..0000000 --- a/examples/jms/static-selector-jms/src/main/resources/hornetq/server0/activemq-jms.xml +++ /dev/null @@ -1,10 +0,0 @@ - - - - - - - - \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/static-selector-jms/src/main/resources/hornetq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector-jms/src/main/resources/hornetq/server0/activemq-users.xml b/examples/jms/static-selector-jms/src/main/resources/hornetq/server0/activemq-users.xml deleted file mode 100644 index ae30546..0000000 --- a/examples/jms/static-selector-jms/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/static-selector-jms/src/main/resources/jndi.properties ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector-jms/src/main/resources/jndi.properties b/examples/jms/static-selector-jms/src/main/resources/jndi.properties new file mode 100644 index 0000000..d9b5c6a --- /dev/null +++ b/examples/jms/static-selector-jms/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/static-selector/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector/pom.xml b/examples/jms/static-selector/pom.xml index a8a3f37..2a695ea 100644 --- a/examples/jms/static-selector/pom.xml +++ b/examples/jms/static-selector/pom.xml @@ -51,9 +51,6 @@ org.apache.activemq.jms.example.StaticSelectorExample - - 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/static-selector/readme.html ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector/readme.html b/examples/jms/static-selector/readme.html index bf65656..6f73b53 100644 --- a/examples/jms/static-selector/readme.html +++ b/examples/jms/static-selector/readme.html @@ -32,7 +32,7 @@

In the example code, five messages with different 'color' property values are sent to queue 'selectorQueue'. One consumer is created to receive messages from the queue. Of the five sent messages, two are of 'red' color properties, one is 'blue', - one is 'green' and one has not the 'color' propery at all. The result is that the consumer only gets the two 'red' messages.

+ one is 'green' and one has not the 'color' property at all. The result is that the consumer only gets the two 'red' messages.

Example step-by-step

http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/static-selector/src/main/java/org/apache/activemq/jms/example/StaticSelectorExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector/src/main/java/org/apache/activemq/jms/example/StaticSelectorExample.java b/examples/jms/static-selector/src/main/java/org/apache/activemq/jms/example/StaticSelectorExample.java index 11cc7b3..346134d 100644 --- a/examples/jms/static-selector/src/main/java/org/apache/activemq/jms/example/StaticSelectorExample.java +++ b/examples/jms/static-selector/src/main/java/org/apache/activemq/jms/example/StaticSelectorExample.java @@ -52,7 +52,7 @@ public class StaticSelectorExample extends ActiveMQExample try { // Step 1. Create an initial context to perform the JNDI lookup. - initialContext = getContext(0); + initialContext = new InitialContext(); // Step 2. look-up the JMS queue object from JNDI, this is the queue that has filter configured with it. Queue queue = (Queue)initialContext.lookup("queue/exampleQueue"); @@ -68,9 +68,10 @@ public class StaticSelectorExample extends ActiveMQExample // Step 6. Create a JMS Session Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + Session producerSession = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); // Step 7. Create a JMS Message Producer - MessageProducer producer = session.createProducer(queue); + MessageProducer producer = producerSession.createProducer(queue); // Step 8. Create a JMS Message Consumer that receives 'red' messages MessageConsumer redConsumer = session.createConsumer(queue); @@ -138,7 +139,7 @@ public class StaticSelectorExample extends ActiveMQExample textMessage.getText() + "] with color property: " + colorProp); - if (!colorProp.equals(name)) + if (colorProp != null && !colorProp.equals(name)) { result = false; } http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/static-selector/src/main/resources/activemq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector/src/main/resources/activemq/server0/activemq-configuration.xml b/examples/jms/static-selector/src/main/resources/activemq/server0/activemq-configuration.xml new file mode 100644 index 0000000..d150bc4 --- /dev/null +++ b/examples/jms/static-selector/src/main/resources/activemq/server0/activemq-configuration.xml @@ -0,0 +1,41 @@ + + + ${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 + + + + + +
jms.queue.exampleQueue
+ +
+
+ + + + + + + + + + + + + + + +
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/static-selector/src/main/resources/activemq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector/src/main/resources/activemq/server0/activemq-jms.xml b/examples/jms/static-selector/src/main/resources/activemq/server0/activemq-jms.xml new file mode 100644 index 0000000..847659f --- /dev/null +++ b/examples/jms/static-selector/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/static-selector/src/main/resources/activemq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector/src/main/resources/activemq/server0/activemq-users.xml b/examples/jms/static-selector/src/main/resources/activemq/server0/activemq-users.xml new file mode 100644 index 0000000..ae30546 --- /dev/null +++ b/examples/jms/static-selector/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/static-selector/src/main/resources/hornetq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector/src/main/resources/hornetq/server0/activemq-configuration.xml b/examples/jms/static-selector/src/main/resources/hornetq/server0/activemq-configuration.xml deleted file mode 100644 index 930c70c..0000000 --- a/examples/jms/static-selector/src/main/resources/hornetq/server0/activemq-configuration.xml +++ /dev/null @@ -1,49 +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.selectorQueue
- -
-
- - - - - - - - - - - - - - - -
http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/static-selector/src/main/resources/hornetq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector/src/main/resources/hornetq/server0/activemq-jms.xml b/examples/jms/static-selector/src/main/resources/hornetq/server0/activemq-jms.xml deleted file mode 100644 index 847659f..0000000 --- a/examples/jms/static-selector/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/static-selector/src/main/resources/hornetq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector/src/main/resources/hornetq/server0/activemq-users.xml b/examples/jms/static-selector/src/main/resources/hornetq/server0/activemq-users.xml deleted file mode 100644 index ae30546..0000000 --- a/examples/jms/static-selector/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/static-selector/src/main/resources/jndi.properties ---------------------------------------------------------------------- diff --git a/examples/jms/static-selector/src/main/resources/jndi.properties b/examples/jms/static-selector/src/main/resources/jndi.properties new file mode 100644 index 0000000..d9b5c6a --- /dev/null +++ b/examples/jms/static-selector/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/stomp-websockets/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp-websockets/pom.xml b/examples/jms/stomp-websockets/pom.xml index 3d56027..390e3f5 100644 --- a/examples/jms/stomp-websockets/pom.xml +++ b/examples/jms/stomp-websockets/pom.xml @@ -36,7 +36,7 @@ start - ${basedir}/target/classes/activemq/server0 + ${basedir}/target/classes/activemq/server0
@@ -63,7 +63,7 @@ stop - ${basedir}/target/classes/activemq/server0 + ${basedir}/target/classes/activemq/server0 http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/stomp-websockets/src/main/java/org/apache/activemq/jms/example/StompWebSocketExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/stomp-websockets/src/main/java/org/apache/activemq/jms/example/StompWebSocketExample.java b/examples/jms/stomp-websockets/src/main/java/org/apache/activemq/jms/example/StompWebSocketExample.java index dac21d9..323dc02 100644 --- a/examples/jms/stomp-websockets/src/main/java/org/apache/activemq/jms/example/StompWebSocketExample.java +++ b/examples/jms/stomp-websockets/src/main/java/org/apache/activemq/jms/example/StompWebSocketExample.java @@ -49,7 +49,7 @@ public class StompWebSocketExample extends ActiveMQExample InitialContext initialContext = null; try { - initialContext = getContext(0); + initialContext = new InitialContext(); Topic topic = (Topic)initialContext.lookup("topic/chat"); ConnectionFactory cf = (ConnectionFactory)initialContext.lookup("ConnectionFactory"); connection = cf.createConnection(); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/stomp-websockets/src/main/resources/activemq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp-websockets/src/main/resources/activemq/server0/activemq-configuration.xml b/examples/jms/stomp-websockets/src/main/resources/activemq/server0/activemq-configuration.xml new file mode 100644 index 0000000..60985df --- /dev/null +++ b/examples/jms/stomp-websockets/src/main/resources/activemq/server0/activemq-configuration.xml @@ -0,0 +1,41 @@ + + + ${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 + + + + + org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory + + + + + + + + + + + + + + + + + + + http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/stomp-websockets/src/main/resources/activemq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp-websockets/src/main/resources/activemq/server0/activemq-jms.xml b/examples/jms/stomp-websockets/src/main/resources/activemq/server0/activemq-jms.xml new file mode 100644 index 0000000..048f5d2 --- /dev/null +++ b/examples/jms/stomp-websockets/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/stomp-websockets/src/main/resources/activemq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp-websockets/src/main/resources/activemq/server0/activemq-users.xml b/examples/jms/stomp-websockets/src/main/resources/activemq/server0/activemq-users.xml new file mode 100644 index 0000000..ae30546 --- /dev/null +++ b/examples/jms/stomp-websockets/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/stomp-websockets/src/main/resources/hornetq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp-websockets/src/main/resources/hornetq/server0/activemq-configuration.xml b/examples/jms/stomp-websockets/src/main/resources/hornetq/server0/activemq-configuration.xml deleted file mode 100644 index c74f54a..0000000 --- a/examples/jms/stomp-websockets/src/main/resources/hornetq/server0/activemq-configuration.xml +++ /dev/null @@ -1,49 +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 - - - - - org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory - - - - - - - - - - - - - - - - - - - http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/stomp-websockets/src/main/resources/hornetq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp-websockets/src/main/resources/hornetq/server0/activemq-jms.xml b/examples/jms/stomp-websockets/src/main/resources/hornetq/server0/activemq-jms.xml deleted file mode 100644 index 048f5d2..0000000 --- a/examples/jms/stomp-websockets/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/stomp-websockets/src/main/resources/hornetq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp-websockets/src/main/resources/hornetq/server0/activemq-users.xml b/examples/jms/stomp-websockets/src/main/resources/hornetq/server0/activemq-users.xml deleted file mode 100644 index ae30546..0000000 --- a/examples/jms/stomp-websockets/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/stomp-websockets/src/main/resources/jndi.properties ---------------------------------------------------------------------- diff --git a/examples/jms/stomp-websockets/src/main/resources/jndi.properties b/examples/jms/stomp-websockets/src/main/resources/jndi.properties new file mode 100644 index 0000000..754c087 --- /dev/null +++ b/examples/jms/stomp-websockets/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 +topic.topic/chat=chat \ No newline at end of file http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/stomp/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp/pom.xml b/examples/jms/stomp/pom.xml index ebf7049..627b7c0 100644 --- a/examples/jms/stomp/pom.xml +++ b/examples/jms/stomp/pom.xml @@ -51,9 +51,6 @@ org.apache.activemq.jms.example.StompExample - - tcp://localhost:5445 - @@ -107,7 +104,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/stomp/src/main/java/org/apache/activemq/jms/example/StompExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/stomp/src/main/java/org/apache/activemq/jms/example/StompExample.java b/examples/jms/stomp/src/main/java/org/apache/activemq/jms/example/StompExample.java index a27ae30..bd3f84a 100644 --- a/examples/jms/stomp/src/main/java/org/apache/activemq/jms/example/StompExample.java +++ b/examples/jms/stomp/src/main/java/org/apache/activemq/jms/example/StompExample.java @@ -88,7 +88,7 @@ public class StompExample extends ActiveMQExample // We will now consume from JMS the message sent with Stomp. // Step 6. Create an initial context to perform the JNDI lookup. - initialContext = getContext(0); + initialContext = new InitialContext(); // Step 7. Perform a lookup on the queue and the connection factory Queue queue = (Queue)initialContext.lookup("queue/exampleQueue"); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/stomp/src/main/resources/activemq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp/src/main/resources/activemq/server0/activemq-configuration.xml b/examples/jms/stomp/src/main/resources/activemq/server0/activemq-configuration.xml new file mode 100644 index 0000000..1b68cd8 --- /dev/null +++ b/examples/jms/stomp/src/main/resources/activemq/server0/activemq-configuration.xml @@ -0,0 +1,42 @@ + + + ${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 + + + + + org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory + + + + + + + + + + + + + + + + + + + + http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/stomp/src/main/resources/activemq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp/src/main/resources/activemq/server0/activemq-jms.xml b/examples/jms/stomp/src/main/resources/activemq/server0/activemq-jms.xml new file mode 100644 index 0000000..0d5c953 --- /dev/null +++ b/examples/jms/stomp/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/stomp/src/main/resources/activemq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp/src/main/resources/activemq/server0/activemq-users.xml b/examples/jms/stomp/src/main/resources/activemq/server0/activemq-users.xml new file mode 100644 index 0000000..ae30546 --- /dev/null +++ b/examples/jms/stomp/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/stomp/src/main/resources/hornetq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp/src/main/resources/hornetq/server0/activemq-configuration.xml b/examples/jms/stomp/src/main/resources/hornetq/server0/activemq-configuration.xml deleted file mode 100644 index 0188165..0000000 --- a/examples/jms/stomp/src/main/resources/hornetq/server0/activemq-configuration.xml +++ /dev/null @@ -1,51 +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 - - - - - org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory - - - - - - - - - - - - - - - - - - - - http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/stomp/src/main/resources/hornetq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp/src/main/resources/hornetq/server0/activemq-jms.xml b/examples/jms/stomp/src/main/resources/hornetq/server0/activemq-jms.xml deleted file mode 100644 index 0d5c953..0000000 --- a/examples/jms/stomp/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/stomp/src/main/resources/hornetq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp/src/main/resources/hornetq/server0/activemq-users.xml b/examples/jms/stomp/src/main/resources/hornetq/server0/activemq-users.xml deleted file mode 100644 index ae30546..0000000 --- a/examples/jms/stomp/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/stomp/src/main/resources/jndi.properties ---------------------------------------------------------------------- diff --git a/examples/jms/stomp/src/main/resources/jndi.properties b/examples/jms/stomp/src/main/resources/jndi.properties new file mode 100644 index 0000000..d9b5c6a --- /dev/null +++ b/examples/jms/stomp/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/stomp1.1/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.1/pom.xml b/examples/jms/stomp1.1/pom.xml index 251f5c8..f7db8c0 100644 --- a/examples/jms/stomp1.1/pom.xml +++ b/examples/jms/stomp1.1/pom.xml @@ -51,9 +51,6 @@ org.apache.activemq.jms.example.StompExample - - tcp://localhost:5445 - @@ -107,7 +104,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/stomp1.1/src/main/java/org/apache/activemq/jms/example/StompExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.1/src/main/java/org/apache/activemq/jms/example/StompExample.java b/examples/jms/stomp1.1/src/main/java/org/apache/activemq/jms/example/StompExample.java index 35309c0..17220f9 100644 --- a/examples/jms/stomp1.1/src/main/java/org/apache/activemq/jms/example/StompExample.java +++ b/examples/jms/stomp1.1/src/main/java/org/apache/activemq/jms/example/StompExample.java @@ -95,7 +95,7 @@ public class StompExample extends ActiveMQExample // We will now consume from JMS the message sent with Stomp. // Step 6. Create an initial context to perform the JNDI lookup. - initialContext = getContext(0); + initialContext = new InitialContext(); // Step 7. Perform a lookup on the queue and the connection factory Queue queue = (Queue)initialContext.lookup("queue/exampleQueue"); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/stomp1.1/src/main/resources/activemq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.1/src/main/resources/activemq/server0/activemq-configuration.xml b/examples/jms/stomp1.1/src/main/resources/activemq/server0/activemq-configuration.xml new file mode 100644 index 0000000..1b68cd8 --- /dev/null +++ b/examples/jms/stomp1.1/src/main/resources/activemq/server0/activemq-configuration.xml @@ -0,0 +1,42 @@ + + + ${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 + + + + + org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory + + + + + + + + + + + + + + + + + + + + http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/stomp1.1/src/main/resources/activemq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.1/src/main/resources/activemq/server0/activemq-jms.xml b/examples/jms/stomp1.1/src/main/resources/activemq/server0/activemq-jms.xml new file mode 100644 index 0000000..0d5c953 --- /dev/null +++ b/examples/jms/stomp1.1/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/stomp1.1/src/main/resources/activemq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.1/src/main/resources/activemq/server0/activemq-users.xml b/examples/jms/stomp1.1/src/main/resources/activemq/server0/activemq-users.xml new file mode 100644 index 0000000..ae30546 --- /dev/null +++ b/examples/jms/stomp1.1/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/stomp1.1/src/main/resources/hornetq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.1/src/main/resources/hornetq/server0/activemq-configuration.xml b/examples/jms/stomp1.1/src/main/resources/hornetq/server0/activemq-configuration.xml deleted file mode 100644 index 0188165..0000000 --- a/examples/jms/stomp1.1/src/main/resources/hornetq/server0/activemq-configuration.xml +++ /dev/null @@ -1,51 +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 - - - - - org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory - - - - - - - - - - - - - - - - - - - - http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/stomp1.1/src/main/resources/hornetq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.1/src/main/resources/hornetq/server0/activemq-jms.xml b/examples/jms/stomp1.1/src/main/resources/hornetq/server0/activemq-jms.xml deleted file mode 100644 index 0d5c953..0000000 --- a/examples/jms/stomp1.1/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/stomp1.1/src/main/resources/hornetq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.1/src/main/resources/hornetq/server0/activemq-users.xml b/examples/jms/stomp1.1/src/main/resources/hornetq/server0/activemq-users.xml deleted file mode 100644 index ae30546..0000000 --- a/examples/jms/stomp1.1/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/stomp1.1/src/main/resources/jndi.properties ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.1/src/main/resources/jndi.properties b/examples/jms/stomp1.1/src/main/resources/jndi.properties new file mode 100644 index 0000000..d9b5c6a --- /dev/null +++ b/examples/jms/stomp1.1/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/stomp1.2/pom.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.2/pom.xml b/examples/jms/stomp1.2/pom.xml index 1876e38..2c52fb6 100644 --- a/examples/jms/stomp1.2/pom.xml +++ b/examples/jms/stomp1.2/pom.xml @@ -51,9 +51,6 @@ org.apache.activemq.jms.example.StompExample - - tcp://localhost:5445 - @@ -107,7 +104,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/stomp1.2/src/main/java/org/apache/activemq/jms/example/StompExample.java ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.2/src/main/java/org/apache/activemq/jms/example/StompExample.java b/examples/jms/stomp1.2/src/main/java/org/apache/activemq/jms/example/StompExample.java index 7b21107..f9faf72 100644 --- a/examples/jms/stomp1.2/src/main/java/org/apache/activemq/jms/example/StompExample.java +++ b/examples/jms/stomp1.2/src/main/java/org/apache/activemq/jms/example/StompExample.java @@ -94,7 +94,7 @@ public class StompExample extends ActiveMQExample // We will now consume from JMS the message sent with Stomp. // Step 6. Create an initial context to perform the JNDI lookup. - initialContext = getContext(0); + initialContext = new InitialContext(); // Step 7. Perform a lookup on the queue and the connection factory Queue queue = (Queue)initialContext.lookup("queue/exampleQueue"); http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/stomp1.2/src/main/resources/activemq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.2/src/main/resources/activemq/server0/activemq-configuration.xml b/examples/jms/stomp1.2/src/main/resources/activemq/server0/activemq-configuration.xml new file mode 100644 index 0000000..1b68cd8 --- /dev/null +++ b/examples/jms/stomp1.2/src/main/resources/activemq/server0/activemq-configuration.xml @@ -0,0 +1,42 @@ + + + ${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 + + + + + org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory + + + + + + + + + + + + + + + + + + + + http://git-wip-us.apache.org/repos/asf/activemq-6/blob/a102983d/examples/jms/stomp1.2/src/main/resources/activemq/server0/activemq-jms.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.2/src/main/resources/activemq/server0/activemq-jms.xml b/examples/jms/stomp1.2/src/main/resources/activemq/server0/activemq-jms.xml new file mode 100644 index 0000000..0d5c953 --- /dev/null +++ b/examples/jms/stomp1.2/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/stomp1.2/src/main/resources/activemq/server0/activemq-users.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.2/src/main/resources/activemq/server0/activemq-users.xml b/examples/jms/stomp1.2/src/main/resources/activemq/server0/activemq-users.xml new file mode 100644 index 0000000..ae30546 --- /dev/null +++ b/examples/jms/stomp1.2/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/stomp1.2/src/main/resources/hornetq/server0/activemq-configuration.xml ---------------------------------------------------------------------- diff --git a/examples/jms/stomp1.2/src/main/resources/hornetq/server0/activemq-configuration.xml b/examples/jms/stomp1.2/src/main/resources/hornetq/server0/activemq-configuration.xml deleted file mode 100644 index 0188165..0000000 --- a/examples/jms/stomp1.2/src/main/resources/hornetq/server0/activemq-configuration.xml +++ /dev/null @@ -1,51 +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 - - - - - org.apache.activemq.core.remoting.impl.netty.NettyAcceptorFactory - - - - - - - - - - - - - - - - - - - -