Merge PR #160
This commit is contained in:
commit
1ae6f5da3e
|
@ -176,7 +176,7 @@
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.apache.activemq</groupId>
|
<groupId>org.apache.activemq</groupId>
|
||||||
<artifactId>activemq-website</artifactId>
|
<artifactId>activemq-website</artifactId>
|
||||||
<version>6.0.1-SNAPSHOT</version>
|
<version>${project.version}</version>
|
||||||
<classifier>javadoc</classifier>
|
<classifier>javadoc</classifier>
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
|
@ -20,7 +20,7 @@ under the License.
|
||||||
<h1>Apache ActiveMQ Examples</h1>
|
<h1>Apache ActiveMQ Examples</h1>
|
||||||
<h2>JMS Examples</h2>
|
<h2>JMS Examples</h2>
|
||||||
<p>Each example has its own instructions as to how they can be run, but for most of them it is as simple as running
|
<p>Each example has its own instructions as to how they can be run, but for most of them it is as simple as running
|
||||||
<code>mvn verify</code> from the example directory. This will start a broker with the correct configuration, run the
|
<code>mvn verify -Pexample</code> from the example directory. This will start a broker with the correct configuration, run the
|
||||||
example and then stop the server so you will need to make sure there is not a broker already running</p>
|
example and then stop the server so you will need to make sure there is not a broker already running</p>
|
||||||
<p>If you want to run an example against an already running broker then firstly you will need to start the broker to use
|
<p>If you want to run an example against an already running broker then firstly you will need to start the broker to use
|
||||||
the examples configuration. An example configuration is provided which by default to run the queue example, to run this
|
the examples configuration. An example configuration is provided which by default to run the queue example, to run this
|
||||||
|
@ -31,7 +31,6 @@ directory for the journal, to avoid problems it is best to delete this directory
|
||||||
set the <code>ACTIVEMQ_DATA_DIR</code> environment property in <code>activemq.conf</code>to use a different location</p>
|
set the <code>ACTIVEMQ_DATA_DIR</code> environment property in <code>activemq.conf</code>to use a different location</p>
|
||||||
<ol>
|
<ol>
|
||||||
<li><a href="./jms/aerogear/readme.html">AeroGear Example</a></li>
|
<li><a href="./jms/aerogear/readme.html">AeroGear Example</a></li>
|
||||||
<li><a href="./jms/applet/readme.html">Applet Example</a></li>
|
|
||||||
<li><a href="./jms/application-layer-failover/readme.html">Application-Layer Failover Example</a></li>
|
<li><a href="./jms/application-layer-failover/readme.html">Application-Layer Failover Example</a></li>
|
||||||
<li><a href="./jms/bridge/readme.html">Core Bridge Example</a></li>
|
<li><a href="./jms/bridge/readme.html">Core Bridge Example</a></li>
|
||||||
<li><a href="./jms/browser/readme.html">JMS QueueBrowser Example</a></li>
|
<li><a href="./jms/browser/readme.html">JMS QueueBrowser Example</a></li>
|
||||||
|
|
|
@ -17,7 +17,7 @@ JMS Examples
|
||||||
============
|
============
|
||||||
|
|
||||||
To run a JMS example, simply `cd` into the appropriate example directory
|
To run a JMS example, simply `cd` into the appropriate example directory
|
||||||
and type `mvn verify` (For details please read the readme.html in each
|
and type `mvn verify -Pexample` (For details please read the readme.html in each
|
||||||
example directory).
|
example directory).
|
||||||
|
|
||||||
Here's a listing of the examples with a brief description.
|
Here's a listing of the examples with a brief description.
|
||||||
|
|
|
@ -62,9 +62,6 @@ under the License.
|
||||||
<profiles>
|
<profiles>
|
||||||
<profile>
|
<profile>
|
||||||
<id>default</id>
|
<id>default</id>
|
||||||
<activation>
|
|
||||||
<activeByDefault>true</activeByDefault>
|
|
||||||
</activation>
|
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
|
|
@ -36,4 +36,16 @@ under the License.
|
||||||
<udp-address>231.7.7.7</udp-address>
|
<udp-address>231.7.7.7</udp-address>
|
||||||
</properties>
|
</properties>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>release</id>
|
||||||
|
<modules>
|
||||||
|
<module>embedded</module>
|
||||||
|
<module>embedded-remote</module>
|
||||||
|
<module>perf</module>
|
||||||
|
<module>vertx-connector</module>
|
||||||
|
</modules>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -84,7 +84,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -180,6 +182,8 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -4,13 +4,13 @@ Running the ActiveMQ Examples
|
||||||
To run an individual example firstly cd into the example directory and run
|
To run an individual example firstly cd into the example directory and run
|
||||||
|
|
||||||
```
|
```
|
||||||
mvn verify
|
mvn verify -Pexample
|
||||||
```
|
```
|
||||||
|
|
||||||
If you are running against an un released version, i.e. from master branch, you will have to run `mvn install` on the root
|
If you are running against an un released version, i.e. from master branch, you will have to run `mvn install` on the root
|
||||||
pom.xml and the example/activemq-jms-examples-common/pom.xml first.
|
pom.xml and the example/activemq-jms-examples-common/pom.xml first.
|
||||||
|
|
||||||
If you want to run all the examples (except those that need to be run standalone) you can run `mvn verify` in the examples
|
If you want to run all the examples (except those that need to be run standalone) you can run `mvn verify -Pexample` in the examples
|
||||||
directory but before you do you will need to up the memory used by running:
|
directory but before you do you will need to up the memory used by running:
|
||||||
|
|
||||||
```
|
```
|
||||||
|
|
|
@ -50,6 +50,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -149,5 +152,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -1,36 +0,0 @@
|
||||||
<!--
|
|
||||||
Licensed to the Apache Software Foundation (ASF) under one
|
|
||||||
or more contributor license agreements. See the NOTICE file
|
|
||||||
distributed with this work for additional information
|
|
||||||
regarding copyright ownership. The ASF licenses this file
|
|
||||||
to you under the Apache License, Version 2.0 (the
|
|
||||||
"License"); you may not use this file except in compliance
|
|
||||||
with the License. You may obtain a copy of the License at
|
|
||||||
|
|
||||||
http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
|
|
||||||
Unless required by applicable law or agreed to in writing,
|
|
||||||
software distributed under the License is distributed on an
|
|
||||||
"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
|
||||||
KIND, either express or implied. See the License for the
|
|
||||||
specific language governing permissions and limitations
|
|
||||||
under the License.
|
|
||||||
-->
|
|
||||||
|
|
||||||
<html>
|
|
||||||
<head>
|
|
||||||
<title>ActiveMQ Applet Example</title>
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<h1>ActiveMQ Applet Example</h1>
|
|
||||||
|
|
||||||
<p>The Applet will connect to ActiveMQ server running on localhost and
|
|
||||||
publishes messages on a topic <code>exampleTopic</code> when "Send" is pressed.</p>
|
|
||||||
<p>The Applet is also a MessageListener and will display messages received from the topic</p>
|
|
||||||
|
|
||||||
<applet code="org.apache.activemq.jms.example.AppletExample.class"
|
|
||||||
codebase="build/classes/"
|
|
||||||
archive="activemq-core-client.jar,activemq-jms-client.jar,geronimo-jms_2.0_spec.jar,netty.jar"
|
|
||||||
width="640" height="480"></applet>
|
|
||||||
</body>
|
|
||||||
</html>
|
|
|
@ -1,144 +0,0 @@
|
||||||
<?xml version='1.0'?>
|
|
||||||
<!--
|
|
||||||
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>
|
|
||||||
|
|
||||||
<parent>
|
|
||||||
<groupId>org.apache.activemq.examples.jms</groupId>
|
|
||||||
<artifactId>jms-examples</artifactId>
|
|
||||||
<version>6.0.1-SNAPSHOT</version>
|
|
||||||
</parent>
|
|
||||||
|
|
||||||
<artifactId>activemq-jms-applet-example</artifactId>
|
|
||||||
<packaging>jar</packaging>
|
|
||||||
<name>ActiveMQ6 JMS Applet Example</name>
|
|
||||||
|
|
||||||
<dependencies>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.apache.activemq.examples.jms</groupId>
|
|
||||||
<artifactId>activemq-jms-examples-common</artifactId>
|
|
||||||
<version>${project.version}</version>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>io.netty</groupId>
|
|
||||||
<artifactId>netty-all</artifactId>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.apache.geronimo.specs</groupId>
|
|
||||||
<artifactId>geronimo-jms_2.0_spec</artifactId>
|
|
||||||
</dependency>
|
|
||||||
</dependencies>
|
|
||||||
|
|
||||||
<build>
|
|
||||||
<plugins>
|
|
||||||
<plugin>
|
|
||||||
<groupId>org.apache.activemq</groupId>
|
|
||||||
<artifactId>activemq-maven-plugin</artifactId>
|
|
||||||
<executions>
|
|
||||||
<execution>
|
|
||||||
<id>start0</id>
|
|
||||||
<goals>
|
|
||||||
<goal>start</goal>
|
|
||||||
</goals>
|
|
||||||
<configuration>
|
|
||||||
<configurationDir>${basedir}/target/classes/activemq/server0</configurationDir>
|
|
||||||
</configuration>
|
|
||||||
</execution>
|
|
||||||
<execution>
|
|
||||||
<id>runClient</id>
|
|
||||||
<goals>
|
|
||||||
<goal>runClient</goal>
|
|
||||||
</goals>
|
|
||||||
<configuration>
|
|
||||||
<clientClass>org.apache.activemq.jms.example.AppletExample</clientClass>
|
|
||||||
<args>
|
|
||||||
<param>tcp://localhost:61616</param>
|
|
||||||
</args>
|
|
||||||
<systemProperties>
|
|
||||||
<property>
|
|
||||||
<name>exampleConfigDir</name>
|
|
||||||
<value>${basedir}/target/classes/activemq</value>
|
|
||||||
</property>
|
|
||||||
</systemProperties>
|
|
||||||
</configuration>
|
|
||||||
</execution>
|
|
||||||
<execution>
|
|
||||||
<id>stop0</id>
|
|
||||||
<goals>
|
|
||||||
<goal>stop</goal>
|
|
||||||
</goals>
|
|
||||||
<configuration>
|
|
||||||
<configurationDir>${basedir}/target/classes/activemq/server0</configurationDir>
|
|
||||||
</configuration>
|
|
||||||
</execution>
|
|
||||||
</executions>
|
|
||||||
<dependencies>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.apache.activemq.examples.jms</groupId>
|
|
||||||
<artifactId>activemq-jms-applet-example</artifactId>
|
|
||||||
<version>${project.version}</version>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.apache.activemq</groupId>
|
|
||||||
<artifactId>activemq-core-client</artifactId>
|
|
||||||
<version>${project.version}</version>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.apache.activemq</groupId>
|
|
||||||
<artifactId>activemq-server</artifactId>
|
|
||||||
<version>${project.version}</version>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.apache.activemq</groupId>
|
|
||||||
<artifactId>activemq-jms-client</artifactId>
|
|
||||||
<version>${project.version}</version>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.apache.activemq</groupId>
|
|
||||||
<artifactId>activemq-jms-server</artifactId>
|
|
||||||
<version>${project.version}</version>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>io.netty</groupId>
|
|
||||||
<artifactId>netty-all</artifactId>
|
|
||||||
<version>${netty.version}</version>
|
|
||||||
</dependency>
|
|
||||||
<dependency>
|
|
||||||
<groupId>org.apache.geronimo.specs</groupId>
|
|
||||||
<artifactId>geronimo-jms_2.0_spec</artifactId>
|
|
||||||
<version>${geronimo.jms.2.spec.version}</version>
|
|
||||||
</dependency>
|
|
||||||
</dependencies>
|
|
||||||
<configuration>
|
|
||||||
<waitOnStart>false</waitOnStart>
|
|
||||||
<systemProperties>
|
|
||||||
<property>
|
|
||||||
<name>data.dir</name>
|
|
||||||
<value>${basedir}/target/</value>
|
|
||||||
</property>
|
|
||||||
</systemProperties>
|
|
||||||
</configuration>
|
|
||||||
</plugin>
|
|
||||||
</plugins>
|
|
||||||
</build>
|
|
||||||
|
|
||||||
</project>
|
|
|
@ -1,40 +0,0 @@
|
||||||
<!--
|
|
||||||
Licensed to the Apache Software Foundation (ASF) under one
|
|
||||||
or more contributor license agreements. See the NOTICE file
|
|
||||||
distributed with this work for additional information
|
|
||||||
regarding copyright ownership. The ASF licenses this file
|
|
||||||
to you under the Apache License, Version 2.0 (the
|
|
||||||
"License"); you may not use this file except in compliance
|
|
||||||
with the License. You may obtain a copy of the License at
|
|
||||||
|
|
||||||
http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
|
|
||||||
Unless required by applicable law or agreed to in writing,
|
|
||||||
software distributed under the License is distributed on an
|
|
||||||
"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
|
||||||
KIND, either express or implied. See the License for the
|
|
||||||
specific language governing permissions and limitations
|
|
||||||
under the License.
|
|
||||||
-->
|
|
||||||
|
|
||||||
<html>
|
|
||||||
<head>
|
|
||||||
<title>ActiveMQ Applet Example</title>
|
|
||||||
<link rel="stylesheet" type="text/css" href="../common/common.css" />
|
|
||||||
<link rel="stylesheet" type="text/css" href="../common/prettify.css" />
|
|
||||||
<script type="text/javascript" src="../common/prettify.js"></script>
|
|
||||||
</head>
|
|
||||||
<body onload="prettyPrint()">
|
|
||||||
<h1>Applet Example</h1>
|
|
||||||
<p>This example shows you how to send and receive JMS messages from an Applet.</p>
|
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
|
||||||
|
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i> to start
|
|
||||||
the ActiveMQ server and an HTTP server.</p>
|
|
||||||
|
|
||||||
<p>Then, go to <a href="http://127.0.0.1:8088/applet.html">http://127.0.0.1:8088/applet.html</a> to load
|
|
||||||
and use the applet.</p>
|
|
||||||
|
|
||||||
</body>
|
|
||||||
</html>
|
|
|
@ -1,294 +0,0 @@
|
||||||
/**
|
|
||||||
* Licensed to the Apache Software Foundation (ASF) under one or more
|
|
||||||
* contributor license agreements. See the NOTICE file distributed with
|
|
||||||
* this work for additional information regarding copyright ownership.
|
|
||||||
* The ASF licenses this file to You under the Apache License, Version 2.0
|
|
||||||
* (the "License"); you may not use this file except in compliance with
|
|
||||||
* the License. You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
package org.apache.activemq.jms.example;
|
|
||||||
|
|
||||||
import java.awt.Color;
|
|
||||||
import java.awt.GridBagConstraints;
|
|
||||||
import java.awt.GridBagLayout;
|
|
||||||
import java.awt.event.ActionEvent;
|
|
||||||
import java.awt.event.ActionListener;
|
|
||||||
import java.util.Date;
|
|
||||||
import java.util.HashMap;
|
|
||||||
import java.util.Map;
|
|
||||||
|
|
||||||
import javax.jms.Connection;
|
|
||||||
import javax.jms.ConnectionFactory;
|
|
||||||
import javax.jms.Destination;
|
|
||||||
import javax.jms.JMSException;
|
|
||||||
import javax.jms.Message;
|
|
||||||
import javax.jms.MessageConsumer;
|
|
||||||
import javax.jms.MessageListener;
|
|
||||||
import javax.jms.MessageProducer;
|
|
||||||
import javax.jms.Session;
|
|
||||||
import javax.jms.TextMessage;
|
|
||||||
import javax.swing.BorderFactory;
|
|
||||||
import javax.swing.JApplet;
|
|
||||||
import javax.swing.JButton;
|
|
||||||
import javax.swing.JFrame;
|
|
||||||
import javax.swing.JLabel;
|
|
||||||
import javax.swing.JPanel;
|
|
||||||
import javax.swing.JScrollPane;
|
|
||||||
import javax.swing.JTextArea;
|
|
||||||
import javax.swing.SwingConstants;
|
|
||||||
import javax.swing.SwingUtilities;
|
|
||||||
|
|
||||||
import org.apache.activemq.api.core.TransportConfiguration;
|
|
||||||
import org.apache.activemq.api.jms.ActiveMQJMSClient;
|
|
||||||
import org.apache.activemq.api.jms.JMSFactoryType;
|
|
||||||
import org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* A AppletExample
|
|
||||||
*
|
|
||||||
* @author <a href="mailto:jmesnil@redaht.com>Jeff Mesnil</a>
|
|
||||||
*
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class AppletExample extends JApplet implements ActionListener
|
|
||||||
{
|
|
||||||
|
|
||||||
// Constants -----------------------------------------------------
|
|
||||||
|
|
||||||
// Attributes ----------------------------------------------------
|
|
||||||
|
|
||||||
// Static --------------------------------------------------------
|
|
||||||
|
|
||||||
// Constructors --------------------------------------------------
|
|
||||||
|
|
||||||
/**
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
private static final long serialVersionUID = -2129589098734805722L;
|
|
||||||
|
|
||||||
private Destination destination;
|
|
||||||
|
|
||||||
private Connection connection;
|
|
||||||
|
|
||||||
private MessageProducer producer;
|
|
||||||
|
|
||||||
private MessageConsumer consumer;
|
|
||||||
|
|
||||||
private JTextArea display;
|
|
||||||
|
|
||||||
private JButton sendButton;
|
|
||||||
|
|
||||||
private Session session;
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void init()
|
|
||||||
{
|
|
||||||
super.init();
|
|
||||||
|
|
||||||
try
|
|
||||||
{
|
|
||||||
SwingUtilities.invokeAndWait(new Runnable()
|
|
||||||
{
|
|
||||||
public void run()
|
|
||||||
{
|
|
||||||
createGUI();
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
catch (Exception e)
|
|
||||||
{
|
|
||||||
System.err.println("createGUI didn't successfully complete");
|
|
||||||
}
|
|
||||||
|
|
||||||
Map<String, Object> params = new HashMap<String, Object>();
|
|
||||||
TransportConfiguration connector = new TransportConfiguration(NettyConnectorFactory.class.getName(), params);
|
|
||||||
ConnectionFactory cf = (ConnectionFactory)ActiveMQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, connector);
|
|
||||||
destination = ActiveMQJMSClient.createTopic("exampleTopic");
|
|
||||||
|
|
||||||
try
|
|
||||||
{
|
|
||||||
connection = cf.createConnection();
|
|
||||||
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
|
|
||||||
producer = session.createProducer(destination);
|
|
||||||
consumer = session.createConsumer(destination);
|
|
||||||
consumer.setMessageListener(new MessageListener()
|
|
||||||
{
|
|
||||||
public void onMessage(final Message msg)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
SwingUtilities.invokeAndWait(new Runnable()
|
|
||||||
{
|
|
||||||
public void run()
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
display.setText(display.getText() + "\n" + ((TextMessage)msg).getText());
|
|
||||||
}
|
|
||||||
catch (JMSException e)
|
|
||||||
{
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
catch (Exception e)
|
|
||||||
{
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
catch (JMSException e)
|
|
||||||
{
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void start()
|
|
||||||
{
|
|
||||||
super.start();
|
|
||||||
|
|
||||||
try
|
|
||||||
{
|
|
||||||
connection.start();
|
|
||||||
}
|
|
||||||
catch (JMSException e)
|
|
||||||
{
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void stop()
|
|
||||||
{
|
|
||||||
System.out.println("close connection");
|
|
||||||
if (connection != null)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
connection.close();
|
|
||||||
}
|
|
||||||
catch (JMSException e)
|
|
||||||
{
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
super.stop();
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
// Public --------------------------------------------------------
|
|
||||||
|
|
||||||
public static void main(final String[] args) throws Exception
|
|
||||||
{
|
|
||||||
|
|
||||||
final AppletExample applet = new AppletExample();
|
|
||||||
applet.init();
|
|
||||||
|
|
||||||
JFrame frame = new JFrame("Applet Example");
|
|
||||||
frame.getContentPane().add(applet);
|
|
||||||
|
|
||||||
frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
|
|
||||||
frame.pack();
|
|
||||||
frame.setVisible(true);
|
|
||||||
|
|
||||||
applet.start();
|
|
||||||
System.out.println("open up the applet.html file in a browser, press enter to stop the example");
|
|
||||||
System.in.read();
|
|
||||||
Runtime.getRuntime().addShutdownHook(new Thread()
|
|
||||||
{
|
|
||||||
@Override
|
|
||||||
public void run()
|
|
||||||
{
|
|
||||||
applet.stop();
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
public void actionPerformed(final ActionEvent e)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
producer.send(session.createTextMessage(new Date().toString()));
|
|
||||||
}
|
|
||||||
catch (JMSException e1)
|
|
||||||
{
|
|
||||||
e1.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Package protected ---------------------------------------------
|
|
||||||
|
|
||||||
// Protected -----------------------------------------------------
|
|
||||||
|
|
||||||
// Private -------------------------------------------------------
|
|
||||||
|
|
||||||
private void createGUI()
|
|
||||||
{
|
|
||||||
JPanel contentPane = new JPanel(new GridBagLayout());
|
|
||||||
GridBagConstraints c = new GridBagConstraints();
|
|
||||||
int numColumns = 3;
|
|
||||||
|
|
||||||
JLabel l1 = new JLabel("Received Messages:", SwingConstants.CENTER);
|
|
||||||
c.gridx = 0;
|
|
||||||
c.gridy = 0;
|
|
||||||
c.anchor = GridBagConstraints.SOUTH;
|
|
||||||
c.gridwidth = numColumns;
|
|
||||||
contentPane.add(l1, c);
|
|
||||||
|
|
||||||
display = new JTextArea(5, 20);
|
|
||||||
JScrollPane scrollPane = new JScrollPane(display);
|
|
||||||
display.setEditable(false);
|
|
||||||
display.setForeground(Color.gray);
|
|
||||||
c.gridy = 1;
|
|
||||||
c.gridwidth = numColumns;
|
|
||||||
c.anchor = GridBagConstraints.CENTER;
|
|
||||||
c.weighty = 1.0;
|
|
||||||
c.fill = GridBagConstraints.BOTH;
|
|
||||||
contentPane.add(scrollPane, c);
|
|
||||||
|
|
||||||
sendButton = new JButton("Send");
|
|
||||||
c.gridy = 2;
|
|
||||||
c.gridwidth = 1;
|
|
||||||
c.anchor = GridBagConstraints.SOUTH;
|
|
||||||
c.weighty = 0.0;
|
|
||||||
c.fill = GridBagConstraints.NONE;
|
|
||||||
contentPane.add(sendButton, c);
|
|
||||||
|
|
||||||
sendButton.addActionListener(this);
|
|
||||||
|
|
||||||
JButton clearButton = new JButton("Clear");
|
|
||||||
c.gridx = 2;
|
|
||||||
c.weightx = 0.0;
|
|
||||||
c.anchor = GridBagConstraints.SOUTHEAST;
|
|
||||||
c.fill = GridBagConstraints.NONE;
|
|
||||||
contentPane.add(clearButton, c);
|
|
||||||
|
|
||||||
clearButton.addActionListener(new ActionListener()
|
|
||||||
{
|
|
||||||
public void actionPerformed(final ActionEvent e)
|
|
||||||
{
|
|
||||||
display.setText("");
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
// Finish setting up the content pane and its border.
|
|
||||||
contentPane.setBorder(BorderFactory.createCompoundBorder(BorderFactory.createLineBorder(Color.black),
|
|
||||||
BorderFactory.createEmptyBorder(5, 20, 5, 10)));
|
|
||||||
setContentPane(contentPane);
|
|
||||||
}
|
|
||||||
|
|
||||||
// Inner classes -------------------------------------------------
|
|
||||||
|
|
||||||
}
|
|
|
@ -1,81 +0,0 @@
|
||||||
/**
|
|
||||||
* Licensed to the Apache Software Foundation (ASF) under one or more
|
|
||||||
* contributor license agreements. See the NOTICE file distributed with
|
|
||||||
* this work for additional information regarding copyright ownership.
|
|
||||||
* The ASF licenses this file to You under the Apache License, Version 2.0
|
|
||||||
* (the "License"); you may not use this file except in compliance with
|
|
||||||
* the License. You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
package org.apache.activemq.jms.example;
|
|
||||||
|
|
||||||
import java.net.InetSocketAddress;
|
|
||||||
import java.util.concurrent.Executors;
|
|
||||||
|
|
||||||
import org.apache.activemq.common.example.ActiveMQExample;
|
|
||||||
import io.netty.bootstrap.ServerBootstrap;
|
|
||||||
import io.netty.channel.socket.nio.NioServerSocketChannelFactory;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* A HttpServer
|
|
||||||
*
|
|
||||||
* * @author The Netty Project (netty-dev@lists.jboss.org)
|
|
||||||
* @author Trustin Lee (tlee@redhat.com)
|
|
||||||
* @author <a href="mailto:jmesnil@redhat.com>Jeff Mesnil</a>
|
|
||||||
*
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class HttpStaticFileServer extends ActiveMQExample
|
|
||||||
{
|
|
||||||
|
|
||||||
public static void main(final String[] args)
|
|
||||||
{
|
|
||||||
new HttpStaticFileServer().run(args);
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public boolean runExample() throws Exception
|
|
||||||
{
|
|
||||||
// Configure the server.
|
|
||||||
ServerBootstrap bootstrap = new ServerBootstrap(new NioServerSocketChannelFactory(Executors.newCachedThreadPool(),
|
|
||||||
Executors.newCachedThreadPool()));
|
|
||||||
// Set up the event pipeline factory.
|
|
||||||
bootstrap.setPipelineFactory(new HttpStaticFileServerPipelineFactory());
|
|
||||||
// Bind and start to accept incoming connections.
|
|
||||||
bootstrap.bind(new InetSocketAddress(8088));
|
|
||||||
|
|
||||||
System.out.println("HTTP server ready to server on 8088");
|
|
||||||
|
|
||||||
System.out.println("open http://127.0.0.1:8088/applet.html to use the Applet");
|
|
||||||
|
|
||||||
while (true)
|
|
||||||
{
|
|
||||||
Thread.sleep(100);
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
// Attributes ----------------------------------------------------
|
|
||||||
|
|
||||||
// Static --------------------------------------------------------
|
|
||||||
|
|
||||||
// Constructors --------------------------------------------------
|
|
||||||
|
|
||||||
// Public --------------------------------------------------------
|
|
||||||
|
|
||||||
// Package protected ---------------------------------------------
|
|
||||||
|
|
||||||
// Protected -----------------------------------------------------
|
|
||||||
|
|
||||||
// Private -------------------------------------------------------
|
|
||||||
|
|
||||||
// Inner classes -------------------------------------------------
|
|
||||||
|
|
||||||
}
|
|
|
@ -1,189 +0,0 @@
|
||||||
/**
|
|
||||||
* Licensed to the Apache Software Foundation (ASF) under one or more
|
|
||||||
* contributor license agreements. See the NOTICE file distributed with
|
|
||||||
* this work for additional information regarding copyright ownership.
|
|
||||||
* The ASF licenses this file to You under the Apache License, Version 2.0
|
|
||||||
* (the "License"); you may not use this file except in compliance with
|
|
||||||
* the License. You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
package org.apache.activemq.jms.example;
|
|
||||||
|
|
||||||
import java.io.File;
|
|
||||||
import java.io.FileNotFoundException;
|
|
||||||
import java.io.RandomAccessFile;
|
|
||||||
import java.io.UnsupportedEncodingException;
|
|
||||||
import java.net.URLDecoder;
|
|
||||||
|
|
||||||
import io.netty.buffer.ChannelBuffers;
|
|
||||||
import io.netty.channel.Channel;
|
|
||||||
import io.netty.channel.ChannelFuture;
|
|
||||||
import io.netty.channel.ChannelFutureListener;
|
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
|
||||||
import io.netty.channel.ChannelPipelineCoverage;
|
|
||||||
import io.netty.channel.ExceptionEvent;
|
|
||||||
import io.netty.channel.MessageEvent;
|
|
||||||
import io.netty.channel.SimpleChannelUpstreamHandler;
|
|
||||||
import io.netty.handler.codec.frame.TooLongFrameException;
|
|
||||||
import io.netty.handler.codec.http.DefaultHttpResponse;
|
|
||||||
import io.netty.handler.codec.http.HttpHeaders;
|
|
||||||
import io.netty.handler.codec.http.HttpMethod;
|
|
||||||
import io.netty.handler.codec.http.HttpRequest;
|
|
||||||
import io.netty.handler.codec.http.HttpResponse;
|
|
||||||
import io.netty.handler.codec.http.HttpResponseStatus;
|
|
||||||
import io.netty.handler.codec.http.HttpVersion;
|
|
||||||
import io.netty.handler.stream.ChunkedFile;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* A HttpStaticFileServerHandler
|
|
||||||
*
|
|
||||||
* @author The Netty Project (netty-dev@lists.jboss.org)
|
|
||||||
* @author Trustin Lee (tlee@redhat.com)
|
|
||||||
* @author <a href="mailto:jmesnil@redhat.com>Jeff Mesnil</a>
|
|
||||||
*
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
@ChannelPipelineCoverage("one")
|
|
||||||
public class HttpStaticFileServerHandler extends SimpleChannelUpstreamHandler
|
|
||||||
{
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void messageReceived(final ChannelHandlerContext ctx, final MessageEvent e) throws Exception
|
|
||||||
{
|
|
||||||
HttpRequest request = (HttpRequest)e.getMessage();
|
|
||||||
if (request.getMethod() != HttpMethod.GET)
|
|
||||||
{
|
|
||||||
sendError(ctx, HttpResponseStatus.METHOD_NOT_ALLOWED);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (request.isChunked())
|
|
||||||
{
|
|
||||||
sendError(ctx, HttpResponseStatus.BAD_REQUEST);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
String path = sanitizeUri(request.getUri());
|
|
||||||
if (path == null)
|
|
||||||
{
|
|
||||||
sendError(ctx, HttpResponseStatus.FORBIDDEN);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
File file = new File(path);
|
|
||||||
if (file.isHidden() || !file.exists())
|
|
||||||
{
|
|
||||||
sendError(ctx, HttpResponseStatus.NOT_FOUND);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (!file.isFile())
|
|
||||||
{
|
|
||||||
sendError(ctx, HttpResponseStatus.FORBIDDEN);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
RandomAccessFile raf;
|
|
||||||
try
|
|
||||||
{
|
|
||||||
raf = new RandomAccessFile(file, "r");
|
|
||||||
}
|
|
||||||
catch (FileNotFoundException fnfe)
|
|
||||||
{
|
|
||||||
sendError(ctx, HttpResponseStatus.NOT_FOUND);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
long fileLength = raf.length();
|
|
||||||
|
|
||||||
HttpResponse response = new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK);
|
|
||||||
response.setHeader(HttpHeaders.Names.CONTENT_LENGTH, String.valueOf(fileLength));
|
|
||||||
|
|
||||||
Channel ch = e.getChannel();
|
|
||||||
|
|
||||||
// Write the initial line and the header.
|
|
||||||
ch.write(response);
|
|
||||||
|
|
||||||
// Write the content.
|
|
||||||
ChannelFuture writeFuture = ch.write(new ChunkedFile(raf, 0, fileLength, 8192));
|
|
||||||
|
|
||||||
// Decide whether to close the connection or not.
|
|
||||||
boolean close = HttpHeaders.Values.CLOSE.equalsIgnoreCase(request.getHeader(HttpHeaders.Names.CONNECTION)) || request.getProtocolVersion()
|
|
||||||
.equals(HttpVersion.HTTP_1_0) &&
|
|
||||||
!HttpHeaders.Values.KEEP_ALIVE.equalsIgnoreCase(request.getHeader(HttpHeaders.Names.CONNECTION));
|
|
||||||
|
|
||||||
if (close)
|
|
||||||
{
|
|
||||||
// Close the connection when the whole content is written out.
|
|
||||||
writeFuture.addListener(ChannelFutureListener.CLOSE);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
|
||||||
public void exceptionCaught(final ChannelHandlerContext ctx, final ExceptionEvent e) throws Exception
|
|
||||||
{
|
|
||||||
Channel ch = e.getChannel();
|
|
||||||
Throwable cause = e.getCause();
|
|
||||||
if (cause instanceof TooLongFrameException)
|
|
||||||
{
|
|
||||||
sendError(ctx, HttpResponseStatus.BAD_REQUEST);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
cause.printStackTrace();
|
|
||||||
if (ch.isConnected())
|
|
||||||
{
|
|
||||||
sendError(ctx, HttpResponseStatus.INTERNAL_SERVER_ERROR);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private String sanitizeUri(String uri)
|
|
||||||
{
|
|
||||||
// Decode the path.
|
|
||||||
try
|
|
||||||
{
|
|
||||||
uri = URLDecoder.decode(uri, "UTF-8");
|
|
||||||
}
|
|
||||||
catch (UnsupportedEncodingException e)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
uri = URLDecoder.decode(uri, "ISO-8859-1");
|
|
||||||
}
|
|
||||||
catch (UnsupportedEncodingException e1)
|
|
||||||
{
|
|
||||||
throw new Error();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// Convert file separators.
|
|
||||||
uri = uri.replace('/', File.separatorChar);
|
|
||||||
|
|
||||||
// Simplistic dumb security check.
|
|
||||||
// You will have to do something serious in the production environment.
|
|
||||||
if (uri.contains(File.separator + ".") || uri.contains("." + File.separator) ||
|
|
||||||
uri.startsWith(".") ||
|
|
||||||
uri.endsWith("."))
|
|
||||||
{
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Convert to absolute path.
|
|
||||||
return System.getProperty("user.dir") + File.separator + uri;
|
|
||||||
}
|
|
||||||
|
|
||||||
private void sendError(final ChannelHandlerContext ctx, final HttpResponseStatus status)
|
|
||||||
{
|
|
||||||
HttpResponse response = new DefaultHttpResponse(HttpVersion.HTTP_1_1, status);
|
|
||||||
response.setHeader(HttpHeaders.Names.CONTENT_TYPE, "text/plain; charset=UTF-8");
|
|
||||||
response.setContent(ChannelBuffers.copiedBuffer("Failure: " + status.toString() + "\r\n", "UTF-8"));
|
|
||||||
|
|
||||||
// Close the connection as soon as the error message is sent.
|
|
||||||
ctx.getChannel().write(response).addListener(ChannelFutureListener.CLOSE);
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -1,68 +0,0 @@
|
||||||
/**
|
|
||||||
* Licensed to the Apache Software Foundation (ASF) under one or more
|
|
||||||
* contributor license agreements. See the NOTICE file distributed with
|
|
||||||
* this work for additional information regarding copyright ownership.
|
|
||||||
* The ASF licenses this file to You under the Apache License, Version 2.0
|
|
||||||
* (the "License"); you may not use this file except in compliance with
|
|
||||||
* the License. You may obtain a copy of the License at
|
|
||||||
*
|
|
||||||
* http://www.apache.org/licenses/LICENSE-2.0
|
|
||||||
*
|
|
||||||
* Unless required by applicable law or agreed to in writing, software
|
|
||||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
||||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
||||||
* See the License for the specific language governing permissions and
|
|
||||||
* limitations under the License.
|
|
||||||
*/
|
|
||||||
package org.apache.activemq.jms.example;
|
|
||||||
|
|
||||||
import io.netty.channel.ChannelPipeline;
|
|
||||||
import io.netty.channel.ChannelPipelineFactory;
|
|
||||||
import io.netty.channel.Channels;
|
|
||||||
import io.netty.handler.codec.http.HttpRequestDecoder;
|
|
||||||
import io.netty.handler.codec.http.HttpResponseEncoder;
|
|
||||||
import io.netty.handler.stream.ChunkedWriteHandler;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* A HttpStaticFileServerPipelineFactory
|
|
||||||
*
|
|
||||||
* @author The Netty Project (netty-dev@lists.jboss.org)
|
|
||||||
* @author Trustin Lee (tlee@redhat.com)
|
|
||||||
* @author <a href="mailto:jmesnil@redhat.com>Jeff Mesnil</a>
|
|
||||||
*
|
|
||||||
*
|
|
||||||
*/
|
|
||||||
public class HttpStaticFileServerPipelineFactory implements ChannelPipelineFactory
|
|
||||||
{
|
|
||||||
public ChannelPipeline getPipeline() throws Exception
|
|
||||||
{
|
|
||||||
// Create a default pipeline implementation.
|
|
||||||
ChannelPipeline pipeline = Channels.pipeline();
|
|
||||||
|
|
||||||
pipeline.addLast("decoder", new HttpRequestDecoder());
|
|
||||||
pipeline.addLast("encoder", new HttpResponseEncoder());
|
|
||||||
pipeline.addLast("chunkedWriter", new ChunkedWriteHandler());
|
|
||||||
|
|
||||||
pipeline.addLast("handler", new HttpStaticFileServerHandler());
|
|
||||||
return pipeline;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Constants -----------------------------------------------------
|
|
||||||
|
|
||||||
// Attributes ----------------------------------------------------
|
|
||||||
|
|
||||||
// Static --------------------------------------------------------
|
|
||||||
|
|
||||||
// Constructors --------------------------------------------------
|
|
||||||
|
|
||||||
// Public --------------------------------------------------------
|
|
||||||
|
|
||||||
// Package protected ---------------------------------------------
|
|
||||||
|
|
||||||
// Protected -----------------------------------------------------
|
|
||||||
|
|
||||||
// Private -------------------------------------------------------
|
|
||||||
|
|
||||||
// Inner classes -------------------------------------------------
|
|
||||||
|
|
||||||
}
|
|
|
@ -1,61 +0,0 @@
|
||||||
<?xml version='1.0'?>
|
|
||||||
<!--
|
|
||||||
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.
|
|
||||||
-->
|
|
||||||
|
|
||||||
<configuration xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
|
|
||||||
xmlns="urn:activemq"
|
|
||||||
xsi:schemaLocation="urn:activemq /schema/activemq-server.xsd">
|
|
||||||
|
|
||||||
<jms xmlns="urn:activemq-jms">
|
|
||||||
<!--the topic used by the example-->
|
|
||||||
<topic name="exampleTopic"/>
|
|
||||||
</jms>
|
|
||||||
|
|
||||||
<core xmlns="urn:activemq:core">
|
|
||||||
|
|
||||||
<bindings-directory>${data.dir}/server0/data/messaging/bindings</bindings-directory>
|
|
||||||
|
|
||||||
<journal-directory>${data.dir}/server0/data/messaging/journal</journal-directory>
|
|
||||||
|
|
||||||
<large-messages-directory>${data.dir}/server0/data/messaging/largemessages</large-messages-directory>
|
|
||||||
|
|
||||||
<paging-directory>${data.dir}/server0/data/messaging/paging</paging-directory>
|
|
||||||
|
|
||||||
<!-- Acceptors -->
|
|
||||||
<acceptors>
|
|
||||||
<acceptor name="netty-acceptor">tcp://localhost:61616</acceptor>
|
|
||||||
</acceptors>
|
|
||||||
|
|
||||||
<!-- Other config -->
|
|
||||||
|
|
||||||
<security-settings>
|
|
||||||
<!--security for example topic-->
|
|
||||||
<security-setting match="jms.topic.exampleTopic">
|
|
||||||
<permission type="createDurableQueue" roles="guest"/>
|
|
||||||
<permission type="deleteDurableQueue" roles="guest"/>
|
|
||||||
<permission type="createNonDurableQueue" roles="guest"/>
|
|
||||||
<permission type="deleteNonDurableQueue" roles="guest"/>
|
|
||||||
<permission type="consume" roles="guest"/>
|
|
||||||
<permission type="send" roles="guest"/>
|
|
||||||
</security-setting>
|
|
||||||
</security-settings>
|
|
||||||
</core>
|
|
||||||
|
|
||||||
</core>
|
|
||||||
</configuration>
|
|
|
@ -1,17 +0,0 @@
|
||||||
## ---------------------------------------------------------------------------
|
|
||||||
## 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.
|
|
||||||
## ---------------------------------------------------------------------------
|
|
||||||
guest=guest
|
|
|
@ -1,17 +0,0 @@
|
||||||
## ---------------------------------------------------------------------------
|
|
||||||
## 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.
|
|
||||||
## ---------------------------------------------------------------------------
|
|
||||||
guest=guest
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -152,5 +155,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -42,7 +42,7 @@ under the License.
|
||||||
section of the user manual.</p>
|
section of the user manual.</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
<p>In this example, the live server is server 1, which will failover onto server 0.</p>
|
<p>In this example, the live server is server 1, which will failover onto server 0.</p>
|
||||||
<p>The connection will initially be created to server1, server 1 will crash, and the client will carry on
|
<p>The connection will initially be created to server1, server 1 will crash, and the client will carry on
|
||||||
on server 0, the new server. With Application-Layer failover the node that is failed over onto, does not need to
|
on server 0, the new server. With Application-Layer failover the node that is failed over onto, does not need to
|
||||||
|
|
|
@ -49,6 +49,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -161,5 +164,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -70,7 +70,7 @@ under the License.
|
||||||
</code>
|
</code>
|
||||||
</pre>
|
</pre>
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li>We create an initial context for looking up JNDI on node 0</li>
|
<li>We create an initial context for looking up JNDI on node 0</li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -125,5 +128,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -36,7 +36,7 @@ under the License.
|
||||||
the queue (looking at the message without removing them) and finally consume the 2 messages
|
the queue (looking at the message without removing them) and finally consume the 2 messages
|
||||||
</p>
|
</p>
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
||||||
|
|
|
@ -49,6 +49,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -150,5 +153,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -50,7 +50,7 @@ under the License.
|
||||||
</p>
|
</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><em>To run the example, simply type <code>mvn verify</code> from this directory</em></p>
|
<p><em>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</em></p>
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get its properties from <a href="src/main/resources/activemq/server0/client-jndi.properties">client-jndi.properties</a></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get its properties from <a href="src/main/resources/activemq/server0/client-jndi.properties">client-jndi.properties</a></li>
|
||||||
<pre class="prettyprint">
|
<pre class="prettyprint">
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -173,5 +176,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -33,7 +33,7 @@ under the License.
|
||||||
but after a while the first server will crash. This will trigger an fail-over event.</p>
|
but after a while the first server will crash. This will trigger an fail-over event.</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><em>To run the example, simply type <code>mvn verify</code> from this directory</em></p>
|
<p><em>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</em></p>
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get its properties from <a href="src/main/resources/activemq/server0/client-jndi.properties">client-jndi.properties</a></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get its properties from <a href="src/main/resources/activemq/server0/client-jndi.properties">client-jndi.properties</a></li>
|
||||||
<pre class="prettyprint">
|
<pre class="prettyprint">
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -193,5 +196,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -45,7 +45,7 @@ under the License.
|
||||||
section of the user manual.</p>
|
section of the user manual.</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li> Get an initial context for looking up JNDI from server 0.</li>
|
<li> Get an initial context for looking up JNDI from server 0.</li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -168,5 +171,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -60,7 +60,7 @@ under the License.
|
||||||
section of the user manual.</p>
|
section of the user manual.</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li> Get an initial context for looking up JNDI from server 0.</li>
|
<li> Get an initial context for looking up JNDI from server 0.</li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -206,5 +209,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -78,7 +78,7 @@ under the License.
|
||||||
<p>For more information on ActiveMQ clustering and grouping see the clustering and grouping
|
<p>For more information on ActiveMQ clustering and grouping see the clustering and grouping
|
||||||
section of the user manual.</p>
|
section of the user manual.</p>
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li> Get an initial context for looking up JNDI from server 0.</li>
|
<li> Get an initial context for looking up JNDI from server 0.</li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -160,5 +163,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -156,5 +159,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -51,7 +51,7 @@ under the License.
|
||||||
<p>For more information on ActiveMQ load balancing, and clustering in general, please see the clustering
|
<p>For more information on ActiveMQ load balancing, and clustering in general, please see the clustering
|
||||||
section of the user manual.</p>
|
section of the user manual.</p>
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li> Get an initial context for looking up JNDI from server 0.</li>
|
<li> Get an initial context for looking up JNDI from server 0.</li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -185,5 +188,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -43,7 +43,7 @@ under the License.
|
||||||
</code>
|
</code>
|
||||||
</pre>
|
</pre>
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i>. This will
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i>. This will
|
||||||
automatically start the 3 cluster nodes, each with its specific configuration.</p>
|
automatically start the 3 cluster nodes, each with its specific configuration.</p>
|
||||||
<p>To start the tests <em>manually</em>, the following steps are:</p>
|
<p>To start the tests <em>manually</em>, the following steps are:</p>
|
||||||
<ul>
|
<ul>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -196,5 +199,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -54,7 +54,7 @@ under the License.
|
||||||
<p>For more information on ActiveMQ load balancing, and clustering in general, please see the clustering
|
<p>For more information on ActiveMQ load balancing, and clustering in general, please see the clustering
|
||||||
section of the user manual.</p>
|
section of the user manual.</p>
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li> Get an initial context for looking up JNDI from server 0.</li>
|
<li> Get an initial context for looking up JNDI from server 0.</li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -176,5 +179,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -60,7 +60,7 @@ under the License.
|
||||||
<p>For more information on ActiveMQ load balancing, and clustering in general, please see the clustering
|
<p>For more information on ActiveMQ load balancing, and clustering in general, please see the clustering
|
||||||
section of the user manual.</p>
|
section of the user manual.</p>
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li> Get an initial context for looking up JNDI from server 0.</li>
|
<li> Get an initial context for looking up JNDI from server 0.</li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -176,5 +179,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -51,7 +51,7 @@ under the License.
|
||||||
<p>For more information on ActiveMQ load balancing, and clustering in general, please see the clustering
|
<p>For more information on ActiveMQ load balancing, and clustering in general, please see the clustering
|
||||||
section of the user manual.</p>
|
section of the user manual.</p>
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li> Get an initial context for looking up JNDI from server 0.</li>
|
<li> Get an initial context for looking up JNDI from server 0.</li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -162,5 +165,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -60,7 +60,7 @@ under the License.
|
||||||
<p> One other thing to notice is that the cluster connection has its reconnect attempts set to 5, this is so it will
|
<p> One other thing to notice is that the cluster connection has its reconnect attempts set to 5, this is so it will
|
||||||
disconnect instead of trying to reconnect to a backup that doesn't exist.</p>
|
disconnect instead of trying to reconnect to a backup that doesn't exist.</p>
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li> Get an initial context for looking up JNDI for both servers</li>
|
<li> Get an initial context for looking up JNDI for both servers</li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -162,5 +165,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -52,7 +52,7 @@ under the License.
|
||||||
<p>notice that we have used a template to set some sensible defaults but overridden the backup strategy so back ups
|
<p>notice that we have used a template to set some sensible defaults but overridden the backup strategy so back ups
|
||||||
are full servers</p>
|
are full servers</p>
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li> Get an initial context for looking up JNDI for both servers</li>
|
<li> Get an initial context for looking up JNDI for both servers</li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -127,5 +130,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -52,7 +52,7 @@ under the License.
|
||||||
<p>We then simply consume as many messages as we can in 10 seconds and note how many messages are actually consumed.</p>
|
<p>We then simply consume as many messages as we can in 10 seconds and note how many messages are actually consumed.</p>
|
||||||
<p>We note that the number of messages consumed per second never exceeds the specified value of <code>10</code> messages per second.</p>
|
<p>We note that the number of messages consumed per second never exceeds the specified value of <code>10</code> messages per second.</p>
|
||||||
|
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li>Create an initial context to perform the JNDI lookup.</li>
|
<li>Create an initial context to perform the JNDI lookup.</li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -127,5 +130,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -63,7 +63,7 @@ under the License.
|
||||||
</pre>
|
</pre>
|
||||||
</p>
|
</p>
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
||||||
<pre class="prettyprint">
|
<pre class="prettyprint">
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -125,5 +128,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -51,7 +51,7 @@ under the License.
|
||||||
</address-setting>
|
</address-setting>
|
||||||
</code>
|
</code>
|
||||||
</pre>
|
</pre>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
<ol>
|
<ol>
|
||||||
<li>Create an initial context to perform the JNDI lookup.</li>
|
<li>Create an initial context to perform the JNDI lookup.</li>
|
||||||
<pre class="prettyprint">
|
<pre class="prettyprint">
|
||||||
|
|
|
@ -49,6 +49,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -161,5 +164,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -115,7 +115,7 @@ under the License.
|
||||||
</code>
|
</code>
|
||||||
</pre>
|
</pre>
|
||||||
|
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li>Create an initial context to perform the JNDI lookup on the London server</li>
|
<li>Create an initial context to perform the JNDI lookup on the London server</li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -127,5 +130,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -35,7 +35,7 @@ under the License.
|
||||||
be persisted, the messages sent to them must be marked as persistent messages.</p>
|
be persisted, the messages sent to them must be marked as persistent messages.</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
||||||
|
|
|
@ -54,6 +54,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -124,5 +127,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -30,7 +30,7 @@ under the License.
|
||||||
<p>This examples shows how to setup and run an embedded JMS server using ActiveMQ along with ActiveMQ configuration files.</p>
|
<p>This examples shows how to setup and run an embedded JMS server using ActiveMQ along with ActiveMQ configuration files.</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li>Create ActiveMQ core configuration files and make sure they are within your classpath. By default, ActiveMQ
|
<li>Create ActiveMQ core configuration files and make sure they are within your classpath. By default, ActiveMQ
|
||||||
|
|
|
@ -54,6 +54,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -124,5 +127,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -34,7 +34,7 @@ under the License.
|
||||||
We will setup and run a full-fledged JMS server which binds its JMS resources to JNDI and can be accessed by remote clients.</p>
|
We will setup and run a full-fledged JMS server which binds its JMS resources to JNDI and can be accessed by remote clients.</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li>Create ActiveMQ core configuration, and set the properties accordingly</li>
|
<li>Create ActiveMQ core configuration, and set the properties accordingly</li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -127,5 +130,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -58,7 +58,7 @@ under the License.
|
||||||
</pre>
|
</pre>
|
||||||
</p>
|
</p>
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
||||||
<pre class="prettyprint">
|
<pre class="prettyprint">
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -162,5 +165,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -133,5 +136,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -46,7 +46,7 @@ under the License.
|
||||||
</pre>
|
</pre>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
||||||
|
|
|
@ -54,6 +54,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -137,5 +140,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -45,7 +45,7 @@ under the License.
|
||||||
javadoc.</p>
|
javadoc.</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li>Instead of looking it up from JNDI we directly instantiate the JMS Queue object. We
|
<li>Instead of looking it up from JNDI we directly instantiate the JMS Queue object. We
|
||||||
|
|
|
@ -49,6 +49,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -132,5 +135,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -61,7 +61,7 @@ under the License.
|
||||||
is not to be called. Return <code>false</code> to abort processing of the packet.</p>
|
is not to be called. Return <code>false</code> to abort processing of the packet.</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -124,5 +127,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -31,7 +31,7 @@ under the License.
|
||||||
<p>In this instance we auto close a connection after a subsequent call to a JMS producer send fails</p>
|
<p>In this instance we auto close a connection after a subsequent call to a JMS producer send fails</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
||||||
|
|
|
@ -49,6 +49,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -161,5 +164,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -109,7 +109,7 @@ under the License.
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p>To run the example after having setup both ActiveMQ servers and the JMS bridge:</p>
|
<p>To run the example after having setup both ActiveMQ servers and the JMS bridge:</p>
|
||||||
<ol>
|
<ol>
|
||||||
<li>To run the example simply run <code>mvn verify</code></li>
|
<li>To run the example simply run <code>mvn verify -Pexample</code></li>
|
||||||
</ol>
|
</ol>
|
||||||
<p>Let's look at the Client code (in <code>JMSBridgeExample</code> class):</p>
|
<p>Let's look at the Client code (in <code>JMSBridgeExample</code> class):</p>
|
||||||
<ol>
|
<ol>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -124,5 +127,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -31,7 +31,7 @@ under the License.
|
||||||
the Broker receiving it</p>
|
the Broker receiving it</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -124,5 +127,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -31,7 +31,7 @@ under the License.
|
||||||
<p>A JMSContext is part of JMS 2.0 and combines the JMS Connection and Session Objects into a simple Interface</p>
|
<p>A JMSContext is part of JMS 2.0 and combines the JMS Connection and Session Objects into a simple Interface</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -127,5 +130,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -32,7 +32,7 @@ under the License.
|
||||||
threads and connections.</p>
|
threads and connections.</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
||||||
|
|
|
@ -54,6 +54,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -152,5 +155,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -45,7 +45,7 @@ under the License.
|
||||||
</p>
|
</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><em>To run the example, simply type <code>mvn verify</code> from this directory</em></p>
|
<p><em>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</em></p>
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get its properties from <a href="server0/client-jndi.properties">client-jndi.properties</a></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get its properties from <a href="server0/client-jndi.properties">client-jndi.properties</a></li>
|
||||||
<pre class="prettyprint">
|
<pre class="prettyprint">
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -130,5 +133,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -36,7 +36,7 @@ under the License.
|
||||||
<p>You may also choose to read LargeMessages using the regular ByteStream or ByteMessage methods, but using the InputStream and OutputStream will provide you a much better performance</p>
|
<p>You may also choose to read LargeMessages using the regular ByteStream or ByteMessage methods, but using the InputStream and OutputStream will provide you a much better performance</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
<p>In this example we limit both the server and the client to be running in a maximum of 50MB of RAM,
|
<p>In this example we limit both the server and the client to be running in a maximum of 50MB of RAM,
|
||||||
and we send a message with a body of size 256MB.</p>
|
and we send a message with a body of size 256MB.</p>
|
||||||
<p>ActiveMQ can support much large message sizes but we
|
<p>ActiveMQ can support much large message sizes but we
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -124,5 +127,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -45,7 +45,7 @@ under the License.
|
||||||
</pre>
|
</pre>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <a href="server0/client-jndi.properties">client-jndi.properties</a></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <a href="server0/client-jndi.properties">client-jndi.properties</a></li>
|
||||||
<pre class="prettyprint">
|
<pre class="prettyprint">
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -124,5 +127,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -61,7 +61,7 @@ under the License.
|
||||||
</pre>
|
</pre>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><em>To run the example, simply type <code>mvn verify</code> from this directory</em></p>
|
<p><em>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</em></p>
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get its properties from <a href="server0/client-jndi.properties">client-jndi.properties</a></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get its properties from <a href="server0/client-jndi.properties">client-jndi.properties</a></li>
|
||||||
<pre class="prettyprint">
|
<pre class="prettyprint">
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -124,5 +127,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -46,7 +46,7 @@ under the License.
|
||||||
</pre>
|
</pre>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><em>To run the example, simply type <code>mvn verify</code> from this directory</em></p>
|
<p><em>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</em></p>
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get its properties from <a href="server0/client-jndi.properties">client-jndi.properties</a></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get its properties from <a href="server0/client-jndi.properties">client-jndi.properties</a></li>
|
||||||
<pre class="prettyprint">
|
<pre class="prettyprint">
|
||||||
|
|
|
@ -49,6 +49,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -147,5 +150,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -47,7 +47,7 @@ under the License.
|
||||||
normal use). You should set these parameters accordingly to the use and throughput of your messages.</p>
|
normal use). You should set these parameters accordingly to the use and throughput of your messages.</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
||||||
<pre class="prettyprint">
|
<pre class="prettyprint">
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -124,5 +127,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -45,7 +45,7 @@ under the License.
|
||||||
be part of this message group.</p>
|
be part of this message group.</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -124,5 +127,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -43,7 +43,7 @@ under the License.
|
||||||
be part of this message group.</p>
|
be part of this message group.</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
||||||
<pre class="prettyprint">
|
<pre class="prettyprint">
|
||||||
|
|
|
@ -44,6 +44,9 @@ under the License.
|
||||||
</dependency>
|
</dependency>
|
||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
|
<profiles>
|
||||||
|
<profile>
|
||||||
|
<id>example</id>
|
||||||
<build>
|
<build>
|
||||||
<plugins>
|
<plugins>
|
||||||
<plugin>
|
<plugin>
|
||||||
|
@ -124,5 +127,7 @@ under the License.
|
||||||
</plugin>
|
</plugin>
|
||||||
</plugins>
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
|
</profile>
|
||||||
|
</profiles>
|
||||||
|
|
||||||
</project>
|
</project>
|
||||||
|
|
|
@ -44,7 +44,7 @@ under the License.
|
||||||
of its being sent first, arrives last.</p>
|
of its being sent first, arrives last.</p>
|
||||||
|
|
||||||
<h2>Example step-by-step</h2>
|
<h2>Example step-by-step</h2>
|
||||||
<p><i>To run the example, simply type <code>mvn verify</code> from this directory</i></p>
|
<p><i>To run the example, simply type <code>mvn verify -Pexample</code> from this directory</i></p>
|
||||||
|
|
||||||
<ol>
|
<ol>
|
||||||
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
<li>First we need to get an initial context so we can look-up the JMS connection factory and destination objects from JNDI. This initial context will get it's properties from the <code>client-jndi.properties</code> file in the directory <code>../common/config</code></li>
|
||||||
|
|
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue