Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-topic/readme.md (from r1438023, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/readme.md) URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-topic/readme.md?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-topic/readme.md&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/readme.md&r1=1438023&r2=1438738&rev=1438738&view=diff ============================================================================== (empty)
Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-topic/src/main/java/example/topic/Publisher.java (from r1438023, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/java/example/topic/Publisher.java) URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-topic/src/main/java/example/topic/Publisher.java?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-topic/src/main/java/example/topic/Publisher.java&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/java/example/topic/Publisher.java&r1=1438023&r2=1438738&rev=1438738&view=diff ============================================================================== --- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/java/example/topic/Publisher.java (original) +++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-topic/src/main/java/example/topic/Publisher.java Fri Jan 25 22:06:13 2013 @@ -16,7 +16,6 @@ */ package example.topic; -import example.util.Util; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; @@ -25,16 +24,17 @@ import javax.jms.*; * @author <a href="http://www.christianposta.com/blog">Christian Posta</a> */ public class Publisher { - private static final String BROKER_HOST = "tcp://localhost:%d"; - private static final int BROKER_PORT = Util.getBrokerPort(); - private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT); + private static final String BROKER_URL = "tcp://localhost:61613"; private static final Boolean NON_TRANSACTED = false; private static final int NUM_MESSAGES_TO_SEND = 100; private static final long DELAY = 100; public static void main(String[] args) { - - ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "password", BROKER_URL); + String url = BROKER_URL; + if (args.length > 0) { + url = args[0].trim(); + } + ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "password", url); Connection connection = null; try { Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-topic/src/main/java/example/topic/Subscriber.java (from r1438023, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/java/example/topic/Subscriber.java) URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-topic/src/main/java/example/topic/Subscriber.java?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-topic/src/main/java/example/topic/Subscriber.java&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/java/example/topic/Subscriber.java&r1=1438023&r2=1438738&rev=1438738&view=diff ============================================================================== --- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/java/example/topic/Subscriber.java (original) +++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-topic/src/main/java/example/topic/Subscriber.java Fri Jan 25 22:06:13 2013 @@ -16,7 +16,6 @@ */ package example.topic; -import example.util.Util; import org.apache.activemq.ActiveMQConnectionFactory; import javax.jms.*; @@ -26,10 +25,8 @@ import java.util.concurrent.CountDownLat * @author <a href="http://www.christianposta.com/blog">Christian Posta</a> */ public class Subscriber implements MessageListener { + private static final String BROKER_URL = "tcp://localhost:61613"; - private static final String BROKER_HOST = "tcp://localhost:%d"; - private static final int BROKER_PORT = Util.getBrokerPort(); - private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT); private static final Boolean NON_TRANSACTED = false; @@ -39,8 +36,12 @@ public class Subscriber implements Messa } public static void main(String[] args) { + String url = BROKER_URL; + if (args.length > 0) { + url = args[0].trim(); + } System.out.println("\nWaiting to receive messages... Either waiting for END message or press Ctrl+C to exit"); - ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "password", BROKER_URL); + ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "password", url); Connection connection = null; final CountDownLatch latch = new CountDownLatch(1); Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-topic/src/main/resources/log4j.properties (from r1438023, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/resources/log4j.properties) URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-topic/src/main/resources/log4j.properties?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-topic/src/main/resources/log4j.properties&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-topic/src/main/resources/log4j.properties&r1=1438023&r2=1438738&rev=1438738&view=diff ============================================================================== (empty) Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-transaction/pom.xml (from r1438023, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-transaction/pom.xml) URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-transaction/pom.xml?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-transaction/pom.xml&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-transaction/pom.xml&r1=1438023&r2=1438738&rev=1438738&view=diff ============================================================================== --- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-transaction/pom.xml (original) +++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-transaction/pom.xml Fri Jan 25 22:06:13 2013 @@ -22,7 +22,7 @@ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <parent> - <artifactId>openwire-example</artifactId> + <artifactId>advanced-openwire-example</artifactId> <groupId>example</groupId> <version>0.1-SNAPSHOT</version> </parent> @@ -30,14 +30,6 @@ <artifactId>jms-example-transaction</artifactId> - <dependencies> - <dependency> - <groupId>${project.groupId}</groupId> - <artifactId>jms-example-util</artifactId> - <version>${project.version}</version> - </dependency> - </dependencies> - <profiles> <profile> <id>client</id> Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-transaction/readme.md (from r1438023, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-transaction/readme.md) URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-transaction/readme.md?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-transaction/readme.md&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-transaction/readme.md&r1=1438023&r2=1438738&rev=1438738&view=diff ============================================================================== (empty) Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-transaction/src/main/java/example/transaction/Client.java (from r1438023, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-transaction/src/main/java/example/transaction/Client.java) URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-transaction/src/main/java/example/transaction/Client.java?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-transaction/src/main/java/example/transaction/Client.java&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-transaction/src/main/java/example/transaction/Client.java&r1=1438023&r2=1438738&rev=1438738&view=diff ============================================================================== --- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-transaction/src/main/java/example/transaction/Client.java (original) +++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-transaction/src/main/java/example/transaction/Client.java Fri Jan 25 22:06:13 2013 @@ -16,7 +16,6 @@ */ package example.transaction; -import example.util.Util; import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.command.ActiveMQTopic; @@ -27,17 +26,18 @@ import java.util.Scanner; * @author <a href="http://www.christianposta.com/blog">Christian Posta</a> */ public class Client { - private static final String BROKER_HOST = "tcp://localhost:%d"; - private static final int BROKER_PORT = Util.getBrokerPort(); - private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT); + private static final String BROKER_URL = "tcp://localhost:61613"; // this is set to true private static final Boolean TRANSACTED = true; private static final Boolean NON_TRANSACTED = false; public static void main(String[] args) { - - ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "password", BROKER_URL); + String url = BROKER_URL; + if (args.length > 0) { + url = args[0].trim(); + } + ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "password", url); Connection connection = null; try { Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-wildcard-consumer/pom.xml (from r1438023, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-wildcard-consumer/pom.xml) URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-wildcard-consumer/pom.xml?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-wildcard-consumer/pom.xml&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-wildcard-consumer/pom.xml&r1=1438023&r2=1438738&rev=1438738&view=diff ============================================================================== --- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-wildcard-consumer/pom.xml (original) +++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-wildcard-consumer/pom.xml Fri Jan 25 22:06:13 2013 @@ -19,7 +19,7 @@ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <parent> - <artifactId>openwire-example</artifactId> + <artifactId>advanced-openwire-example</artifactId> <groupId>example</groupId> <version>0.1-SNAPSHOT</version> </parent> @@ -27,14 +27,6 @@ <artifactId>jms-example-wildcard-consumer</artifactId> - <dependencies> - <dependency> - <groupId>${project.groupId}</groupId> - <artifactId>jms-example-util</artifactId> - <version>${project.version}</version> - </dependency> - </dependencies> - <profiles> <profile> <id>consumer</id> Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-wildcard-consumer/readme.md (from r1438023, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-wildcard-consumer/readme.md) URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-wildcard-consumer/readme.md?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-wildcard-consumer/readme.md&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-wildcard-consumer/readme.md&r1=1438023&r2=1438738&rev=1438738&view=diff ============================================================================== (empty) Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-wildcard-consumer/src/main/java/example/wildcard/Client.java (from r1438023, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-wildcard-consumer/src/main/java/example/wildcard/Client.java) URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-wildcard-consumer/src/main/java/example/wildcard/Client.java?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-wildcard-consumer/src/main/java/example/wildcard/Client.java&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-wildcard-consumer/src/main/java/example/wildcard/Client.java&r1=1438023&r2=1438738&rev=1438738&view=diff ============================================================================== --- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/jms-example-wildcard-consumer/src/main/java/example/wildcard/Client.java (original) +++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/jms-example-wildcard-consumer/src/main/java/example/wildcard/Client.java Fri Jan 25 22:06:13 2013 @@ -16,7 +16,6 @@ */ package example.wildcard; -import example.util.Util; import org.apache.activemq.ActiveMQConnectionFactory; import org.apache.activemq.command.ActiveMQTopic; @@ -28,13 +27,14 @@ import java.util.Scanner; */ public class Client { private static final Boolean NON_TRANSACTED = false; - private static final String BROKER_HOST = "tcp://localhost:%d"; - private static final int BROKER_PORT = Util.getBrokerPort(); - private static final String BROKER_URL = String.format(BROKER_HOST, BROKER_PORT); + private static final String BROKER_URL = "tcp://localhost:61613"; public static void main(String[] args) { - - ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "password", BROKER_URL); + String url = BROKER_URL; + if (args.length > 0) { + url = args[0].trim(); + } + ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("admin", "password", url); Connection connection = null; try { Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/pom.xml (from r1438023, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/pom.xml) URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/pom.xml?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/pom.xml&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/pom.xml&r1=1438023&r2=1438738&rev=1438738&view=diff ============================================================================== --- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/pom.xml (original) +++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/pom.xml Fri Jan 25 22:06:13 2013 @@ -21,7 +21,7 @@ <modelVersion>4.0.0</modelVersion> <groupId>example</groupId> - <artifactId>openwire-example</artifactId> + <artifactId>advanced-openwire-example</artifactId> <packaging>pom</packaging> <version>0.1-SNAPSHOT</version> <modules> @@ -29,7 +29,6 @@ <module>jms-example-topic</module> <module>jms-example-exclusive-consumer</module> <module>jms-example-transaction</module> - <module>jms-example-util</module> <module>jms-example-durable-sub</module> <module>jms-example-wildcard-consumer</module> <module>jms-example-temp-destinations</module> @@ -42,7 +41,7 @@ <description>Apollo OpenWire Java Examples</description> <properties> - <activemq.version>5.6.0</activemq.version> + <activemq.version>5.7.0</activemq.version> </properties> <repositories> Copied: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/readme.md (from r1438023, activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/readme.md) URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/readme.md?p2=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/advanced-scenarios/readme.md&p1=activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/readme.md&r1=1438023&r2=1438738&rev=1438738&view=diff ============================================================================== (empty) Added: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/java/pom.xml URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/java/pom.xml?rev=1438738&view=auto ============================================================================== --- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/java/pom.xml (added) +++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/java/pom.xml Fri Jan 25 22:06:13 2013 @@ -0,0 +1,81 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. +--> +<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> + + <modelVersion>4.0.0</modelVersion> + + <groupId>example</groupId> + <artifactId>openwire-example</artifactId> + <version>0.1-SNAPSHOT</version> + + <name>example</name> + <description>Apollo Openwire Java Examples</description> + + <repositories> + <repository> + <id>Fusesource Snapshots</id> + <url>http://repo.fusesource.com/nexus/content/repositories/snapshots</url> + </repository> + </repositories> + <properties> + <activemq.version>5.7.0</activemq.version> + </properties> + <dependencies> + + <dependency> + <groupId>org.apache.geronimo.specs</groupId> + <artifactId>geronimo-jms_1.1_spec</artifactId> + <version>1.1</version> + </dependency> + <dependency> + <groupId>org.apache.activemq</groupId> + <artifactId>activemq-core</artifactId> + <version>${activemq.version}</version> + </dependency> + </dependencies> + + <build> + <plugins> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-compiler-plugin</artifactId> + <version>2.1</version> + <configuration> + <source>1.6</source> + <target>1.6</target> + </configuration> + </plugin> + + <!-- include all the dependencies into the jar so it's easier to execute the example --> + <plugin> + <groupId>org.fusesource.mvnplugins</groupId> + <artifactId>maven-uberize-plugin</artifactId> + <version>1.14</version> + <executions> + <execution> + <phase>package</phase> + <goals><goal>uberize</goal></goals> + </execution> + </executions> + </plugin> + + </plugins> + </build> + +</project> + Added: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/java/readme.md URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/java/readme.md?rev=1438738&view=auto ============================================================================== --- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/java/readme.md (added) +++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/java/readme.md Fri Jan 25 22:06:13 2013 @@ -0,0 +1,32 @@ +## Overview + +This is an example of how use the Java JMS api with Apollo. + +## Prereqs + +- Install Java SDK +- Install [Maven](http://maven.apache.org/download.html) + +## Building + +Run: + + mvn install + +## Running the Examples + +In one terminal window run: + + java -cp target/openwire-example-0.1-SNAPSHOT.jar example.Listener + +In another terminal window run: + + java -cp target/openwire-example-0.1-SNAPSHOT.jar example.Publisher + +You can control to which server the examples try to connect to by +setting the following environment variables: + +* `APOLLO_HOST` +* `APOLLO_PORT` +* `APOLLO_USER` +* `APOLLO_PASSWORD` Added: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/java/src/main/java/example/Listener.java URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/java/src/main/java/example/Listener.java?rev=1438738&view=auto ============================================================================== --- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/java/src/main/java/example/Listener.java (added) +++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/java/src/main/java/example/Listener.java Fri Jan 25 22:06:13 2013 @@ -0,0 +1,88 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package example; + +import org.apache.activemq.ActiveMQConnectionFactory; +import org.apache.activemq.command.ActiveMQTopic; + +import javax.jms.*; + +class Listener { + + public static void main(String []args) throws JMSException { + + String user = env("APOLLO_USER", "admin"); + String password = env("APOLLO_PASSWORD", "password"); + String host = env("APOLLO_HOST", "localhost"); + int port = Integer.parseInt(env("APOLLO_PORT", "61613")); + String destination = arg(args, 0, "event"); + + ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://" + host + ":" + port); + + Connection connection = factory.createConnection(user, password); + connection.start(); + Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + Destination dest = new ActiveMQTopic(destination); + + MessageConsumer consumer = session.createConsumer(dest); + long start = System.currentTimeMillis(); + long count = 1; + System.out.println("Waiting for messages..."); + while(true) { + Message msg = consumer.receive(); + if( msg instanceof TextMessage ) { + String body = ((TextMessage) msg).getText(); + if( "SHUTDOWN".equals(body)) { + long diff = System.currentTimeMillis() - start; + System.out.println(String.format("Received %d in %.2f seconds", count, (1.0*diff/1000.0))); + break; + } else { + if( count != msg.getIntProperty("id") ) { + System.out.println("mismatch: "+count+"!="+msg.getIntProperty("id")); + } + count = msg.getIntProperty("id"); + + if( count == 0 ) { + start = System.currentTimeMillis(); + } + if( count % 1000 == 0 ) { + System.out.println(String.format("Received %d messages.", count)); + } + count ++; + } + + } else { + System.out.println("Unexpected message type: "+msg.getClass()); + } + } + connection.close(); + } + + private static String env(String key, String defaultValue) { + String rc = System.getenv(key); + if( rc== null ) + return defaultValue; + return rc; + } + + private static String arg(String []args, int index, String defaultValue) { + if( index < args.length ) + return args[index]; + else + return defaultValue; + } +} \ No newline at end of file Added: activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/java/src/main/java/example/Publisher.java URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/java/src/main/java/example/Publisher.java?rev=1438738&view=auto ============================================================================== --- activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/java/src/main/java/example/Publisher.java (added) +++ activemq/activemq-apollo/trunk/apollo-distro/src/main/release/examples/openwire/java/src/main/java/example/Publisher.java Fri Jan 25 22:06:13 2013 @@ -0,0 +1,80 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +package example; + +import org.apache.activemq.ActiveMQConnectionFactory; +import org.apache.activemq.command.ActiveMQTopic; + +import javax.jms.*; + +class Publisher { + + public static void main(String []args) throws JMSException { + + String user = env("APOLLO_USER", "admin"); + String password = env("APOLLO_PASSWORD", "password"); + String host = env("APOLLO_HOST", "localhost"); + int port = Integer.parseInt(env("APOLLO_PORT", "61613")); + String destination = arg(args, 0, "event"); + + int messages = 10000; + int size = 256; + + String DATA = "abcdefghijklmnopqrstuvwxyz"; + String body = ""; + for( int i=0; i < size; i ++) { + body += DATA.charAt(i%DATA.length()); + } + + ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://" + host + ":" + port); + + Connection connection = factory.createConnection(user, password); + connection.start(); + Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + Destination dest = new ActiveMQTopic(destination); + MessageProducer producer = session.createProducer(dest); + producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); + + for( int i=1; i <= messages; i ++) { + TextMessage msg = session.createTextMessage(body); + msg.setIntProperty("id", i); + producer.send(msg); + if( (i % 1000) == 0) { + System.out.println(String.format("Sent %d messages", i)); + } + } + + producer.send(session.createTextMessage("SHUTDOWN")); + connection.close(); + + } + + private static String env(String key, String defaultValue) { + String rc = System.getenv(key); + if( rc== null ) + return defaultValue; + return rc; + } + + private static String arg(String []args, int index, String defaultValue) { + if( index < args.length ) + return args[index]; + else + return defaultValue; + } + +} \ No newline at end of file