JBoss hornetq SVN: r10296 - branches/Branch_2_2_EAP/examples/common.
by do-not-reply＠jboss.org
Author: ataylor
Date: 2011-03-07 07:45:08 -0500 (Mon, 07 Mar 2011)
New Revision: 10296
Modified:
branches/Branch_2_2_EAP/examples/common/build.xml
Log:
exclude stop server failover example from all example run
Modified: branches/Branch_2_2_EAP/examples/common/build.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/common/build.xml 2011-03-07 12:38:06 UTC (rev 10295)
+++ branches/Branch_2_2_EAP/examples/common/build.xml 2011-03-07 12:45:08 UTC (rev 10296)
@@ -209,10 +209,18 @@
<exclude name="jms/perf/build.xml"/>
<exclude name="jms/stomp-websockets/build.xml"/>
<exclude name="jms/spring-integration/build.xml"/>
+ <exclude name="jms/stop-server-failover/build.xml"/>
</fileset>
</subant>
- <echo message="Do not forget to run jms/applet, jms/clustered-standalone, jms/stomp-websockets & jms/jms-bridge examples manually!" />
+ <echo message="Do not forget to run the following examples manually!" />
+ <echo message="twitter-connector"/>
+ <echo message="applet"/>
+ <echo message="jms-bridge"/>
+ <echo message="large-message"/>
+ <echo message="stomp-websockets"/>
+ <echo message="spring-integration"/>
+ <echo message="stop-server-failover"/>
</target>
</project>
14 years, 9 months
- 1
- 0
JBoss hornetq SVN: r10295 - in branches/Branch_2_2_EAP/examples/jms/transaction-failover: server1 and 1 other directories.
by do-not-reply＠jboss.org
Author: ataylor
Date: 2011-03-07 07:38:06 -0500 (Mon, 07 Mar 2011)
New Revision: 10295
Modified:
branches/Branch_2_2_EAP/examples/jms/transaction-failover/server0/hornetq-configuration.xml
branches/Branch_2_2_EAP/examples/jms/transaction-failover/server0/hornetq-jms.xml
branches/Branch_2_2_EAP/examples/jms/transaction-failover/server1/hornetq-configuration.xml
branches/Branch_2_2_EAP/examples/jms/transaction-failover/server1/hornetq-jms.xml
branches/Branch_2_2_EAP/examples/jms/transaction-failover/src/org/hornetq/jms/example/TransactionFailoverExample.java
Log:
fixed transaction failover example
Modified: branches/Branch_2_2_EAP/examples/jms/transaction-failover/server0/hornetq-configuration.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/jms/transaction-failover/server0/hornetq-configuration.xml 2011-03-07 12:06:25 UTC (rev 10294)
+++ branches/Branch_2_2_EAP/examples/jms/transaction-failover/server0/hornetq-configuration.xml 2011-03-07 12:38:06 UTC (rev 10295)
@@ -1,8 +1,14 @@
<configuration xmlns="urn:hornetq"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:hornetq /schema/hornetq-configuration.xsd">
- <live-connector-ref connector-name="live-connector"/>
-
+
+ <clustered>true</clustered>
+
+ <!--we kill the server process so don't need this set to true-->
+ <failover-on-shutdown>false</failover-on-shutdown>
+
+ <shared-store>true</shared-store>
+
<!-- Connectors -->
<connectors>
@@ -10,10 +16,6 @@
<factory-class>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</factory-class>
<param key="port" value="5445"/>
</connector>
- <connector name="live-connector">
- <factory-class>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</factory-class>
- <param key="port" value="5446"/>
- </connector>
</connectors>
<!-- Acceptors -->
@@ -23,7 +25,31 @@
<param key="port" value="5445"/>
</acceptor>
</acceptors>
-
+
+ <broadcast-groups>
+ <broadcast-group name="bg-group1">
+ <group-address>231.7.7.7</group-address>
+ <group-port>9876</group-port>
+ <broadcast-period>1000</broadcast-period>
+ <connector-ref>netty-connector</connector-ref>
+ </broadcast-group>
+ </broadcast-groups>
+
+ <discovery-groups>
+ <discovery-group name="dg-group1">
+ <group-address>231.7.7.7</group-address>
+ <group-port>9876</group-port>
+ <refresh-timeout>60000</refresh-timeout>
+ </discovery-group>
+ </discovery-groups>
+
+ <cluster-connections>
+ <cluster-connection name="my-cluster">
+ <address>jms</address>
+ <connector-ref>netty-connector</connector-ref>
+ <discovery-group-ref discovery-group-name="dg-group1"/>
+ </cluster-connection>
+ </cluster-connections>
<!-- Other config -->
<security-settings>
Modified: branches/Branch_2_2_EAP/examples/jms/transaction-failover/server0/hornetq-jms.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/jms/transaction-failover/server0/hornetq-jms.xml 2011-03-07 12:06:25 UTC (rev 10294)
+++ branches/Branch_2_2_EAP/examples/jms/transaction-failover/server0/hornetq-jms.xml 2011-03-07 12:38:06 UTC (rev 10295)
@@ -9,6 +9,18 @@
<entries>
<entry name="ConnectionFactory"/>
</entries>
+
+ <ha>true</ha>
+ <!-- Pause 1 second between connect attempts -->
+ <retry-interval>1000</retry-interval>
+
+ <!-- Multiply subsequent reconnect pauses by this multiplier. This can be used to
+ implement an exponential back-off. For our purposes we just set to 1.0 so each reconnect
+ pause is the same length -->
+ <retry-interval-multiplier>1.0</retry-interval-multiplier>
+
+ <!-- Try reconnecting an unlimited number of times (-1 means "unlimited") -->
+ <reconnect-attempts>-1</reconnect-attempts>
</connection-factory>
<!--the queue used by the example-->
Modified: branches/Branch_2_2_EAP/examples/jms/transaction-failover/server1/hornetq-configuration.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/jms/transaction-failover/server1/hornetq-configuration.xml 2011-03-07 12:06:25 UTC (rev 10294)
+++ branches/Branch_2_2_EAP/examples/jms/transaction-failover/server1/hornetq-configuration.xml 2011-03-07 12:38:06 UTC (rev 10295)
@@ -1,6 +1,16 @@
<configuration xmlns="urn:hornetq"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:hornetq ../../../src/schema/hornetq-configuration.xsd">
+
+ <clustered>true</clustered>
+
+ <backup>true</backup>
+
+ <!--we kill the server process so don't need this set to true-->
+ <failover-on-shutdown>false</failover-on-shutdown>
+
+ <shared-store>true</shared-store>
+
<!-- Connectors -->
<connectors>
@@ -17,7 +27,37 @@
<param key="port" value="5446"/>
</acceptor>
</acceptors>
-
+
+ <broadcast-groups>
+ <broadcast-group name="bg-group1">
+ <group-address>231.7.7.7</group-address>
+ <group-port>9876</group-port>
+ <broadcast-period>1000</broadcast-period>
+ <connector-ref>netty-connector</connector-ref>
+ </broadcast-group>
+ </broadcast-groups>
+
+ <discovery-groups>
+ <discovery-group name="dg-group1">
+ <group-address>231.7.7.7</group-address>
+ <group-port>9876</group-port>
+ <refresh-timeout>60000</refresh-timeout>
+ </discovery-group>
+ </discovery-groups>
+
+ <cluster-connections>
+ <cluster-connection name="my-cluster">
+ <address>jms</address>
+ <connector-ref>netty-connector</connector-ref>
+ <discovery-group-ref discovery-group-name="dg-group1"/>
+ </cluster-connection>
+ </cluster-connections>
+
+ <large-messages-directory>../server0/data/large-messages</large-messages-directory>
+ <bindings-directory>../server0/data/bindings</bindings-directory>
+ <journal-directory>../server0/data/journal</journal-directory>
+ <paging-directory>../server0/data/paging</paging-directory>
+
<!-- Other config -->
<security-settings>
Modified: branches/Branch_2_2_EAP/examples/jms/transaction-failover/server1/hornetq-jms.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/jms/transaction-failover/server1/hornetq-jms.xml 2011-03-07 12:06:25 UTC (rev 10294)
+++ branches/Branch_2_2_EAP/examples/jms/transaction-failover/server1/hornetq-jms.xml 2011-03-07 12:38:06 UTC (rev 10295)
@@ -9,6 +9,18 @@
<entries>
<entry name="ConnectionFactory"/>
</entries>
+
+ <ha>true</ha>
+ <!-- Pause 1 second between connect attempts -->
+ <retry-interval>1000</retry-interval>
+
+ <!-- Multiply subsequent reconnect pauses by this multiplier. This can be used to
+ implement an exponential back-off. For our purposes we just set to 1.0 so each reconnect
+ pause is the same length -->
+ <retry-interval-multiplier>1.0</retry-interval-multiplier>
+
+ <!-- Try reconnecting an unlimited number of times (-1 means "unlimited") -->
+ <reconnect-attempts>-1</reconnect-attempts>
</connection-factory>
<!--the queue used by the example-->
Modified: branches/Branch_2_2_EAP/examples/jms/transaction-failover/src/org/hornetq/jms/example/TransactionFailoverExample.java
===================================================================
--- branches/Branch_2_2_EAP/examples/jms/transaction-failover/src/org/hornetq/jms/example/TransactionFailoverExample.java 2011-03-07 12:06:25 UTC (rev 10294)
+++ branches/Branch_2_2_EAP/examples/jms/transaction-failover/src/org/hornetq/jms/example/TransactionFailoverExample.java 2011-03-07 12:38:06 UTC (rev 10295)
@@ -50,7 +50,7 @@
try
{
// Step 1. Get an initial context for looking up JNDI from the server #1
- initialContext = getContext(1);
+ initialContext = getContext(0);
// Step 2. Look-up the JMS resources from JNDI
Queue queue = (Queue)initialContext.lookup("/queue/exampleQueue");
14 years, 9 months
- 1
- 0
JBoss hornetq SVN: r10294 - branches/Branch_2_2_EAP/examples/jms/paging/src/org/hornetq/jms/example.
by do-not-reply＠jboss.org
Author: ataylor
Date: 2011-03-07 07:06:25 -0500 (Mon, 07 Mar 2011)
New Revision: 10294
Modified:
branches/Branch_2_2_EAP/examples/jms/paging/src/org/hornetq/jms/example/PagingExample.java
Log:
tweaked paging example to run quicker
Modified: branches/Branch_2_2_EAP/examples/jms/paging/src/org/hornetq/jms/example/PagingExample.java
===================================================================
--- branches/Branch_2_2_EAP/examples/jms/paging/src/org/hornetq/jms/example/PagingExample.java 2011-03-07 11:37:16 UTC (rev 10293)
+++ branches/Branch_2_2_EAP/examples/jms/paging/src/org/hornetq/jms/example/PagingExample.java 2011-03-07 12:06:25 UTC (rev 10294)
@@ -86,8 +86,8 @@
// Step 12. We don't need persistent messages in order to use paging. (This step is optional)
messageProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
- // Step 13. Send the message for about 30K, which should be over the memory limit imposed by the server
- for (int i = 0; i < 30000; i++)
+ // Step 13. Send the message for about 1K, which should be over the memory limit imposed by the server
+ for (int i = 0; i < 1000; i++)
{
messageProducer.send(message);
}
@@ -106,7 +106,7 @@
// paging
// until messages are ACKed
- for (int i = 0; i < 30000; i++)
+ for (int i = 0; i < 1000; i++)
{
message = (BytesMessage)messageConsumer.receive(3000);
14 years, 9 months
- 1
- 0
JBoss hornetq SVN: r10293 - in branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway: server0 and 2 other directories.
by do-not-reply＠jboss.org
Author: ataylor
Date: 2011-03-07 06:37:16 -0500 (Mon, 07 Mar 2011)
New Revision: 10293
Modified:
branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/readme.html
branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/server0/hornetq-configuration.xml
branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/server1/hornetq-configuration.xml
branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/src/org/hornetq/jms/example/ClusterStaticOnewayExample.java
Log:
fixed one way clustered example and wrote read me
Modified: branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/readme.html
===================================================================
--- branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/readme.html 2011-03-07 10:19:59 UTC (rev 10292)
+++ branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/readme.html 2011-03-07 11:37:16 UTC (rev 10293)
@@ -6,29 +6,35 @@
<script type="text/javascript" src="../../common/prettify.js"></script>
</head>
<body onload="prettyPrint()">
- <h1>JMS Load Balanced Static Clustered Queue Example</h1>
+ <h1>JMS Load Balanced Static Clustered One Way Queue Example</h1>
- <p>This example demonstrates a JMS queue deployed on two different nodes. The two nodes are configured to form a cluster
- from a <em>static</em> list of nodes.</p>
+ <p>This example demonstrates a JMS queue deployed on three different nodes. The three nodes are configured to form a one way cluster
+ from a <em>static</em> list of nodes. </p>
+ <p>A one way cluster is different from a symmetrical cluster in that each node is only connected to one another node in
+ a chain type fashion, so server 0 -> server 1 -> server 2</p>
<p>We then create a consumer on the queue on each node, and we create a producer on only one of the nodes.</p>
- <p>We then send some messages via the producer, and we verify that <b>both</b> consumers receive the sent messages
+ <p>We then send some messages via the producer, and we verify that <b>all</b> consumers receive the sent messages
in a round-robin fashion.</p>
<p>In other words, HornetQ <b>load balances</b> the sent messages across all consumers on the cluster</p>
<p>This example uses JNDI to lookup the JMS Queue and ConnectionFactory objects. If you prefer not to use
JNDI, these could be instantiated directly.</p>
- <p>Here's the relevant snippet from the server configuration, which tells the server to form a cluster between the two nodes
- and to load balance the messages between the nodes.</p>
+ <p>Here's the relevant snippet from the server configuration, which tells the server to form a one way cluster between the three nodes
+ and to load balance the messages between the nodes. Note that we have set <em>allow-direct-connections-only</em> to true,
+ this means that this server will only ever connect the address's specified in the list of connectors. ALso notice
+ that <em>max-hops</em> is 2, this is because server 0 is not directly connected to server 2, 2 hops in fact, so we
+ allow any updates from servers up to 2 hops away</p>
<pre class="prettyprint">
- <code><cluster-connection name="my-cluster">
+ <code>
+ <cluster-connection name="my-cluster">
<address>jms</address>
<connector-ref>netty-connector</connector-ref>
<retry-interval>500</retry-interval>
<use-duplicate-detection>true</use-duplicate-detection>
<forward-when-no-consumers>true</forward-when-no-consumers>
- <max-hops>1</max-hops>
- <static-connectors>
- <connector-ref>server1-connector</connector-ref>
- </static-connectors>
+ <max-hops>2</max-hops>
+ <static-connectors allow-direct-connections-only="true">
+ <connector-ref>server1-connector</connector-ref>
+ </static-connectors>
</cluster-connection>
</code>
</pre>
@@ -47,37 +53,46 @@
<li>Look-up the JMS Queue object from JNDI</li>
<pre class="prettyprint">
- <code>Queue queue = (Queue)ic0.lookup("/queue/exampleQueue");</code>
+ <code>
+ Queue queue = (Queue)ic0.lookup("/queue/exampleQueue");
+ </code>
</pre>
<li>Look-up a JMS Connection Factory object from JNDI on server 0</li>
<pre class="prettyprint">
- <code>ConnectionFactory cf0 = (ConnectionFactory)ic0.lookup("/ConnectionFactory");</code>
+ <code>
+ ConnectionFactory cf0 = (ConnectionFactory)ic0.lookup("/ConnectionFactory");
+ </code>
</pre>
- <li>Get an initial context for looking up JNDI from server 1.</li>
+
+ <li>grab an initial connection and wait, in reality you wouldn't do it this way but since we want to ensure an
+ equal load balance we do this and then create 4 connections round robined</li>
<pre class="prettyprint">
- <code>ic1 = getContext(1);</code>
+ <code>
+ initialConnection = cf0.createConnection();
+ </code>
</pre>
- <li>Look-up a JMS Connection Factory object from JNDI on server 1</li>
+ <li>We create a JMS Connection connection0 which is a connection to server 0</li>
<pre class="prettyprint">
- <code>ConnectionFactory cf1 = (ConnectionFactory)ic1.lookup("/ConnectionFactory");
+ <code>
+ connection0 = cf0.createConnection()
</code>
</pre>
- <li>We create a JMS Connection connection0 which is a connection to server 0</li>
+ <li>We create a JMS Connection connection0 which is a connection to server 1</li>
<pre class="prettyprint">
- <code>
- connection0 = cf0.createConnection();
- </code>
+ <code>
+ connection1 = cf0.createConnection()
+ </code>
</pre>
-
- <li>We create a JMS Connection connection1 which is a connection to server 1</li>
+
+ <li>We create a JMS Connection connection0 which is a connection to server 2</li>
<pre class="prettyprint">
- <code>
- connection1 = cf1.createConnection();
- </code>
+ <code>
+ connection2 = cf0.createConnection()
+ </code>
</pre>
<li>We create a JMS Session on server 0</li>
@@ -94,34 +109,49 @@
</code>
</pre>
+ <li>We create a JMS Session on server 1</li>
+ <pre class="prettyprint">
+ <code>
+ Session session2 = connection2.createSession(false, Session.AUTO_ACKNOWLEDGE);
+ </code>
+ </pre>
<li>We start the connections to ensure delivery occurs on them</li>
<pre class="prettyprint">
<code>
connection0.start();
connection1.start();
+
+ connection2.start();
</code>
</pre>
+
<li>We create JMS MessageConsumer objects on server 0 and server 1</li>
<pre class="prettyprint">
<code>
MessageConsumer consumer0 = session0.createConsumer(queue);
- MessageConsumer consumer1 = session1.createConsumer(queue);
+ MessageConsumer consumer2 = session2.createConsumer(queue);
+
+ MessageConsumer consumer3 = session3.createConsumer(queue);
</code>
</pre>
+
<li>We create a JMS MessageProducer object on server 0.</li>
<pre class="prettyprint">
<code>
- MessageProducer producer = session0.createProducer(queue);</code>
+ Session sendSession = getServerConnection(0, connection0, connection1, connection2).createSession(false, Session.AUTO_ACKNOWLEDGE);
+
+ MessageProducer producer = sendSession.createProducer(queue);
+ </code>
</pre>
<li>We send some messages to server 0.</li>
<pre class="prettyprint">
<code>
- final int numMessages = 10;
+ final int numMessages = 18;
for (int i = 0; i < numMessages; i++)
{
@@ -152,6 +182,10 @@
TextMessage message1 = (TextMessage)consumer1.receive(5000);
System.out.println("Got message: " + message1.getText() + " from node 1");
+
+ TextMessage message2 = (TextMessage)consumer2.receive(5000);
+
+ System.out.println("Got message: " + message2.getText() + " from node " + con2Node);
}
</code>
</pre>
@@ -162,15 +196,30 @@
<code>
finally
{
- if (connection0 != null)
- {
- connection0.close();
- }
-
- if (connection1 != null)
- {
- connection1.close();
- }
+ if (initialConnection != null)
+ {
+ initialConnection.close();
+ }
+
+ if (connection0 != null)
+ {
+ connection0.close();
+ }
+
+ if (connection1 != null)
+ {
+ connection1.close();
+ }
+
+ if (connection2 != null)
+ {
+ connection2.close();
+ }
+
+ if (ic0 != null)
+ {
+ ic0.close();
+ }
}
</code>
</pre>
Modified: branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/server0/hornetq-configuration.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/server0/hornetq-configuration.xml 2011-03-07 10:19:59 UTC (rev 10292)
+++ branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/server0/hornetq-configuration.xml 2011-03-07 11:37:16 UTC (rev 10293)
@@ -45,7 +45,7 @@
<retry-interval>500</retry-interval>
<use-duplicate-detection>true</use-duplicate-detection>
<forward-when-no-consumers>true</forward-when-no-consumers>
- <max-hops>1</max-hops>
+ <max-hops>2</max-hops>
<static-connectors allow-direct-connections-only="true">
<connector-ref>server1-connector</connector-ref>
</static-connectors>
Modified: branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/server1/hornetq-configuration.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/server1/hornetq-configuration.xml 2011-03-07 10:19:59 UTC (rev 10292)
+++ branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/server1/hornetq-configuration.xml 2011-03-07 11:37:16 UTC (rev 10293)
@@ -45,7 +45,7 @@
<retry-interval>500</retry-interval>
<use-duplicate-detection>true</use-duplicate-detection>
<forward-when-no-consumers>true</forward-when-no-consumers>
- <max-hops>1</max-hops>
+ <max-hops>2</max-hops>
<static-connectors allow-direct-connections-only="true">
<connector-ref>server2-connector</connector-ref>
</static-connectors>
Modified: branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/src/org/hornetq/jms/example/ClusterStaticOnewayExample.java
===================================================================
--- branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/src/org/hornetq/jms/example/ClusterStaticOnewayExample.java 2011-03-07 10:19:59 UTC (rev 10292)
+++ branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/src/org/hornetq/jms/example/ClusterStaticOnewayExample.java 2011-03-07 11:37:16 UTC (rev 10293)
@@ -42,8 +42,6 @@
Connection connection2 = null;
- Connection connection3 = null;
-
InitialContext ic0 = null;
Thread.sleep(5000);
try
@@ -94,13 +92,28 @@
MessageConsumer consumer2 = session2.createConsumer(queue);
- Thread.sleep(2000);
+ Thread.sleep(4000);
- // Step 13. We create a JMS MessageProducer object on server 2
- MessageProducer producer = session2.createProducer(queue);
+ int con0Node = getServer(connection0);
+ int con1Node = getServer(connection1);
+ int con2Node = getServer(connection2);
- // Step 14. We send some messages to server 2
+ System.out.println("con0Node = " + con0Node);
+ System.out.println("con1Node = " + con1Node);
+ System.out.println("con2Node = " + con2Node);
+ if(con0Node + con1Node + con2Node != 3)
+ {
+ System.out.println("connections not load balanced");
+ return false;
+ }
+ // Step 13. We create a JMS MessageProducer object on server 0
+ Session sendSession = getServerConnection(0, connection0, connection1, connection2).createSession(false, Session.AUTO_ACKNOWLEDGE);
+
+ MessageProducer producer = sendSession.createProducer(queue);
+
+ // Step 14. We send some messages to server 0
+
final int numMessages = 18;
for (int i = 0; i < numMessages; i++)
@@ -112,22 +125,11 @@
System.out.println("Sent message: " + message.getText());
}
Thread.sleep(2000);
- // Step 15. We now consume those messages on *both* server 0,server 1 and 3.
+ // Step 15. We now consume those messages on *both* server 0,server 1 and 2.
// We note the messages have been distributed between servers in a round robin fashion
// JMS Queues implement point-to-point message where each message is only ever consumed by a
// maximum of one consumer
- int con0Node = getServer(connection0);
- int con1Node = getServer(connection1);
- int con2Node = getServer(connection2);
- if(con0Node + con1Node + con2Node != 3)
- {
- System.out.println("connections not load balanced");
- System.out.println("con0Node = " + con0Node);
- System.out.println("con1Node = " + con1Node);
- System.out.println("con2Node = " + con2Node);
- return false;
- }
for (int i = 0; i < numMessages; i += 3)
{
TextMessage message0 = (TextMessage)consumer0.receive(5000);
@@ -141,7 +143,6 @@
TextMessage message2 = (TextMessage)consumer2.receive(5000);
System.out.println("Got message: " + message2.getText() + " from node " + con2Node);
- System.out.println("i = " + i);
}
return true;
@@ -170,11 +171,6 @@
connection2.close();
}
- if (connection3 != null)
- {
- connection3.close();
- }
-
if (ic0 != null)
{
ic0.close();
14 years, 9 months
- 1
- 0
JBoss hornetq SVN: r10292 - branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server.
by do-not-reply＠jboss.org
Author: ataylor
Date: 2011-03-07 05:19:59 -0500 (Mon, 07 Mar 2011)
New Revision: 10292
Modified:
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/ra.xml
Log:
fixed example config
Modified: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/ra.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/ra.xml 2011-03-04 18:09:45 UTC (rev 10291)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/ra.xml 2011-03-07 10:19:59 UTC (rev 10292)
@@ -63,7 +63,7 @@
</description>
<config-property-name>ConnectionParameters</config-property-name>
<config-property-type>java.lang.String</config-property-type>
- <config-property-value>host=127.0.0.1;port=5445,host=127.0.0.1;port=5446</config-property-value>
+ <config-property-value>host=127.0.0.1;port=5446,host=127.0.0.1;port=5447</config-property-value>
</config-property>
<config-property>
<description>Do we support HA</description>
14 years, 9 months
- 1
- 0
JBoss hornetq SVN: r10291 - in branches/Branch_2_2_EAP: hornetq-rest and 1 other directories.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2011-03-04 13:09:45 -0500 (Fri, 04 Mar 2011)
New Revision: 10291
Modified:
branches/Branch_2_2_EAP/build-maven.xml
branches/Branch_2_2_EAP/hornetq-rest/pom.xml
branches/Branch_2_2_EAP/src/config/common/hornetq-version.properties
Log:
upload version
Modified: branches/Branch_2_2_EAP/build-maven.xml
===================================================================
--- branches/Branch_2_2_EAP/build-maven.xml 2011-03-04 18:05:04 UTC (rev 10290)
+++ branches/Branch_2_2_EAP/build-maven.xml 2011-03-04 18:09:45 UTC (rev 10291)
@@ -13,7 +13,7 @@
-->
<project default="upload" name="HornetQ">
- <property name="hornetq.version" value="2.2.1.QA-10280"/>
+ <property name="hornetq.version" value="2.2.1.QA-10291"/>
<property name="build.dir" value="build"/>
<property name="jars.dir" value="${build.dir}/jars"/>
Modified: branches/Branch_2_2_EAP/hornetq-rest/pom.xml
===================================================================
--- branches/Branch_2_2_EAP/hornetq-rest/pom.xml 2011-03-04 18:05:04 UTC (rev 10290)
+++ branches/Branch_2_2_EAP/hornetq-rest/pom.xml 2011-03-04 18:09:45 UTC (rev 10291)
@@ -10,7 +10,7 @@
<properties>
<resteasy.version>2.0.1.GA</resteasy.version>
- <hornetq.version>2.2.1.QA-10280</hornetq.version>
+ <hornetq.version>2.2.1.QA-10291</hornetq.version>
</properties>
<licenses>
Modified: branches/Branch_2_2_EAP/src/config/common/hornetq-version.properties
===================================================================
--- branches/Branch_2_2_EAP/src/config/common/hornetq-version.properties 2011-03-04 18:05:04 UTC (rev 10290)
+++ branches/Branch_2_2_EAP/src/config/common/hornetq-version.properties 2011-03-04 18:09:45 UTC (rev 10291)
@@ -1,4 +1,4 @@
-hornetq.version.versionName=Bzzzzz@10281
+hornetq.version.versionName=Bzzzzz@10291
hornetq.version.majorVersion=2
hornetq.version.minorVersion=2
hornetq.version.microVersion=1
14 years, 9 months
- 1
- 0
JBoss hornetq SVN: r10290 - branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/security.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2011-03-04 13:05:04 -0500 (Fri, 04 Mar 2011)
New Revision: 10290
Modified:
branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/security/SimpleClient.java
Log:
format only
Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/security/SimpleClient.java
===================================================================
--- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/security/SimpleClient.java 2011-03-04 14:40:28 UTC (rev 10289)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/security/SimpleClient.java 2011-03-04 18:05:04 UTC (rev 10290)
@@ -13,6 +13,10 @@
package org.hornetq.tests.integration.security;
+import java.io.PrintStream;
+import java.security.AccessController;
+import java.security.PrivilegedAction;
+
import org.hornetq.api.core.TransportConfiguration;
import org.hornetq.api.core.client.*;
import org.hornetq.core.logging.Logger;
@@ -38,7 +42,6 @@
{
try
{
-
if (args.length != 1)
{
throw new Exception("require 1 argument: connector factory class name");
@@ -57,10 +60,10 @@
ClientConsumer consumer = session.createConsumer(queueName);
ClientMessage message = session.createMessage(HornetQTextMessage.TYPE,
- false,
- 0,
- System.currentTimeMillis(),
- (byte)1);
+ false,
+ 0,
+ System.currentTimeMillis(),
+ (byte)1);
message.getBodyBuffer().writeString(messageText);
producer.send(message);
@@ -87,15 +90,15 @@
}
catch (Throwable t)
{
-
+
String allStack = t.getMessage() + "|";
StackTraceElement[] stackTrace = t.getStackTrace();
for (StackTraceElement stackTraceElement : stackTrace)
{
allStack += stackTraceElement.toString() + "|";
}
- //System.out.println(t.getClass().getName());
- //System.out.println(t.getMessage());
+ // System.out.println(t.getClass().getName());
+ // System.out.println(t.getMessage());
System.out.println(allStack);
System.exit(1);
}
14 years, 9 months
- 1
- 0
JBoss hornetq SVN: r10289 - in branches/Branch_2_2_EAP: examples/javaee/jca-config/server2 and 19 other directories.
by do-not-reply＠jboss.org
Author: ataylor
Date: 2011-03-04 09:40:28 -0500 (Fri, 04 Mar 2011)
New Revision: 10289
Added:
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/backup-server/
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/backup-server/hornetq-configuration.xml
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/backup-server/hornetq-jms.xml
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/build.bat
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/build.sh
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/build.xml
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/config/
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/config/META-INF/
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/config/META-INF/application.xml
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/config/ant.properties
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/config/jndi.properties
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/live-server/
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/live-server/hornetq-configuration.xml
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/live-server/hornetq-jms.xml
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/hornetq-configuration.xml
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/hornetq-jms.xml
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/jms-ds.xml
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/ra.xml
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/src/
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/src/org/
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/src/org/hornetq/
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/src/org/hornetq/javaee/
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/src/org/hornetq/javaee/example/
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/src/org/hornetq/javaee/example/MDBRemoteFailoverStaticClientExample.java
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/src/org/hornetq/javaee/example/server/
branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/src/org/hornetq/javaee/example/server/MDBRemoteFailoverStaticExample.java
Modified:
branches/Branch_2_2_EAP/examples/javaee/jca-config/server2/jms-remote-ds.xml
branches/Branch_2_2_EAP/examples/javaee/jca-config/server2/ra.xml
branches/Branch_2_2_EAP/examples/javaee/jca-remote/server/jms-ds.xml
branches/Branch_2_2_EAP/examples/javaee/jca-remote/server/ra.xml
branches/Branch_2_2_EAP/src/config/jboss-as-4/clustered/ra.xml
branches/Branch_2_2_EAP/src/config/jboss-as-4/non-clustered/ra.xml
branches/Branch_2_2_EAP/src/config/ra.xml
branches/Branch_2_2_EAP/src/main/org/hornetq/ra/ConnectionFactoryProperties.java
branches/Branch_2_2_EAP/src/main/org/hornetq/ra/HornetQRAMCFProperties.java
branches/Branch_2_2_EAP/src/main/org/hornetq/ra/HornetQRAManagedConnectionFactory.java
branches/Branch_2_2_EAP/src/main/org/hornetq/ra/HornetQResourceAdapter.java
branches/Branch_2_2_EAP/src/main/org/hornetq/ra/Util.java
branches/Branch_2_2_EAP/src/main/org/hornetq/ra/inflow/HornetQActivationSpec.java
branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/unit/ra/ResourceAdapterTest.java
Log:
https://issues.jboss.org/browse/JBPAPP-6022 - added support for multiple connectors in Resource Adapter
Modified: branches/Branch_2_2_EAP/examples/javaee/jca-config/server2/jms-remote-ds.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/jca-config/server2/jms-remote-ds.xml 2011-03-03 23:51:36 UTC (rev 10288)
+++ branches/Branch_2_2_EAP/examples/javaee/jca-config/server2/jms-remote-ds.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -15,8 +15,9 @@
<rar-name>hornetq-ra.rar</rar-name>
<connection-definition>org.hornetq.ra.HornetQRAConnectionFactory</connection-definition>
<config-property name="SessionDefaultType" type="java.lang.String">javax.jms.Topic</config-property>
+ <!--if we over ride the connector class we must over ride the params too-->
<config-property name="ConnectorClassName" type="java.lang.String">org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</config-property>
- <config-property name="ConnectionParameters" type="java.lang.String">port=5445</config-property>
+ <config-property name="ConnectionParameters" type="java.lang.String">host=localhost;port=5445</config-property>
<max-pool-size>20</max-pool-size>
</tx-connection-factory>
Modified: branches/Branch_2_2_EAP/examples/javaee/jca-config/server2/ra.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/jca-config/server2/ra.xml 2011-03-03 23:51:36 UTC (rev 10288)
+++ branches/Branch_2_2_EAP/examples/javaee/jca-config/server2/ra.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -36,13 +36,19 @@
<resourceadapter>
<resourceadapter-class>org.hornetq.ra.HornetQResourceAdapter</resourceadapter-class>
<config-property>
- <description>The transport type</description>
+ <description>
+ The transport type. Multiple connectors can be configured by using a comma separated list,
+ i.e. org.hornetq.core.remoting.impl.invm.InVMConnectorFactory,org.hornetq.core.remoting.impl.invm.InVMConnectorFactory.
+ </description>
<config-property-name>ConnectorClassName</config-property-name>
<config-property-type>java.lang.String</config-property-type>
<config-property-value>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</config-property-value>
</config-property>
<config-property>
- <description>The transport configuration. These values must be in the form of key=val;key=val;</description>
+ <description>The transport configuration. These values must be in the form of key=val;key=val;,
+ if multiple connectors are used then each set must be separated by a comma i.e. host=host1;port=5445,host=host2;port=5446.
+ Each set of params maps to the connector classname specified.
+ </description>
<config-property-name>ConnectionParameters</config-property-name>
<config-property-type>java.lang.String</config-property-type>
<config-property-value>host=127.0.0.1;port=5445</config-property-value>
Modified: branches/Branch_2_2_EAP/examples/javaee/jca-remote/server/jms-ds.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/jca-remote/server/jms-ds.xml 2011-03-03 23:51:36 UTC (rev 10288)
+++ branches/Branch_2_2_EAP/examples/javaee/jca-remote/server/jms-ds.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -29,6 +29,7 @@
<rar-name>hornetq-ra.rar</rar-name>
<connection-definition>org.hornetq.ra.HornetQRAConnectionFactory</connection-definition>
<config-property name="SessionDefaultType" type="java.lang.String">javax.jms.Topic</config-property>
+ <!--if we over ride the connector class we must over ride the params too-->
<config-property name="ConnectorClassName" type="java.lang.String">org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</config-property>
<config-property name="ConnectionParameters" type="java.lang.String">host=127.0.0.1;port=5446</config-property>
<max-pool-size>20</max-pool-size>
Modified: branches/Branch_2_2_EAP/examples/javaee/jca-remote/server/ra.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/jca-remote/server/ra.xml 2011-03-03 23:51:36 UTC (rev 10288)
+++ branches/Branch_2_2_EAP/examples/javaee/jca-remote/server/ra.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -49,13 +49,19 @@
<resourceadapter>
<resourceadapter-class>org.hornetq.ra.HornetQResourceAdapter</resourceadapter-class>
<config-property>
- <description>The transport type</description>
+ <description>
+ The transport type. Multiple connectors can be configured by using a comma separated list,
+ i.e. org.hornetq.core.remoting.impl.invm.InVMConnectorFactory,org.hornetq.core.remoting.impl.invm.InVMConnectorFactory.
+ </description>
<config-property-name>ConnectorClassName</config-property-name>
<config-property-type>java.lang.String</config-property-type>
<config-property-value>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</config-property-value>
</config-property>
<config-property>
- <description>The transport configuration. These values must be in the form of key=val;key=val;</description>
+ <description>The transport configuration. These values must be in the form of key=val;key=val;,
+ if multiple connectors are used then each set must be separated by a comma i.e. host=host1;port=5445,host=host2;port=5446.
+ Each set of params maps to the connector classname specified.
+ </description>
<config-property-name>ConnectionParameters</config-property-name>
<config-property-type>java.lang.String</config-property-type>
<config-property-value>host=127.0.0.1;port=5446</config-property-value>
Added: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/backup-server/hornetq-configuration.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/backup-server/hornetq-configuration.xml (rev 0)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/backup-server/hornetq-configuration.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -0,0 +1,108 @@
+<!--
+ ~ Copyright 2009 Red Hat, Inc.
+ ~ Red Hat 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="urn:hornetq"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="urn:hornetq /schema/hornetq-configuration.xsd">
+
+ <name>HornetQ.main.config</name>
+
+ <clustered>true</clustered>
+
+ <failover-on-shutdown>true</failover-on-shutdown>
+
+ <backup>true</backup>
+
+ <shared-store>true</shared-store>
+
+ <!--journal directories-->
+ <large-messages-directory>/tmp/shared/hornetq-data/large-messages</large-messages-directory>
+ <bindings-directory>/tmp/shared/hornetq-data/bindings</bindings-directory>
+ <journal-directory>/tmp/shared/hornetq-data/journal</journal-directory>
+ <paging-directory>/tmp/shared/hornetq-data/paging</paging-directory>
+
+ <!-- Connectors -->
+
+ <connectors>
+ <connector name="netty-connector">
+ <factory-class>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</factory-class>
+ <param key="host" value="${jboss.bind.address:localhost}"/>
+ <param key="port" value="${hornetq.remoting.netty.port:5445}"/>
+ </connector>
+ <connector name="in-vm">
+ <factory-class>org.hornetq.core.remoting.impl.invm.InVMConnectorFactory</factory-class>
+ <param key="server-id" value="${hornetq.server-id:0}"/>
+ </connector>
+ </connectors>
+
+ <!-- Acceptors -->
+ <acceptors>
+ <!-- In VM acceptor -->
+ <acceptor name="in-vm">
+ <factory-class>org.hornetq.core.remoting.impl.invm.InVMAcceptorFactory</factory-class>
+ <param key="server-id" value="${hornetq.server-id:0}"/>
+ </acceptor>
+ <acceptor name="netty-acceptor">
+ <factory-class>org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory</factory-class>
+ <param key="host" value="${jboss.bind.address:localhost}"/>
+ <param key="port" value="${hornetq.remoting.netty.port:5445}"/>
+ </acceptor>
+ </acceptors>
+
+ <broadcast-groups>
+ <broadcast-group name="bg-group1">
+ <group-address>231.7.7.7</group-address>
+ <group-port>9876</group-port>
+ <broadcast-period>1000</broadcast-period>
+ <connector-ref>netty-connector</connector-ref>
+ </broadcast-group>
+ </broadcast-groups>
+
+ <discovery-groups>
+ <discovery-group name="dg-group1">
+ <group-address>231.7.7.7</group-address>
+ <group-port>9876</group-port>
+ <refresh-timeout>60000</refresh-timeout>
+ </discovery-group>
+ </discovery-groups>
+
+ <cluster-connections>
+ <cluster-connection name="my-cluster">
+ <address>jms</address>
+ <connector-ref>netty-connector</connector-ref>
+ <discovery-group-ref discovery-group-name="dg-group1"/>
+ </cluster-connection>
+ </cluster-connections>
+ <!-- Other config -->
+
+ <security-settings>
+ <!--security for example queue-->
+ <security-setting match="jms.queue.inQueue">
+ <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-setting match="jms.queue.outQueue">
+ <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>
+
+</configuration>
Added: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/backup-server/hornetq-jms.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/backup-server/hornetq-jms.xml (rev 0)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/backup-server/hornetq-jms.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -0,0 +1,49 @@
+<!--
+ ~ Copyright 2009 Red Hat, Inc.
+ ~ Red Hat 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="urn:hornetq"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd">
+ <!--the connection factory used by the example-->
+ <connection-factory name="ConnectionFactory">
+ <connectors>
+ <connector-ref connector-name="netty-connector"/>
+ </connectors>
+
+ <entries>
+ <entry name="ConnectionFactory"/>
+ </entries>
+
+ <ha>true</ha>
+ <!-- Pause 1 second between connect attempts -->
+ <retry-interval>1000</retry-interval>
+
+ <!-- Multiply subsequent reconnect pauses by this multiplier. This can be used to
+ implement an exponential back-off. For our purposes we just set to 1.0 so each reconnect
+ pause is the same length -->
+ <retry-interval-multiplier>1.0</retry-interval-multiplier>
+
+ <!-- Try reconnecting an unlimited number of times (-1 means "unlimited") -->
+ <reconnect-attempts>-1</reconnect-attempts>
+ </connection-factory>
+
+ <!--the queue used by the example-->
+ <queue name="inQueue">
+ <entry name="/queue/inQueue"/>
+ </queue>
+
+ <queue name="outQueue">
+ <entry name="/queue/outQueue"/>
+ </queue>
+
+</configuration>
Copied: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/build.bat (from rev 10288, branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover/build.bat)
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/build.bat (rev 0)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/build.bat 2011-03-04 14:40:28 UTC (rev 10289)
@@ -0,0 +1,13 @@
+@echo off
+
+set "OVERRIDE_ANT_HOME=..\..\..\tools\ant"
+
+if exist "..\..\..\src\bin\build.bat" (
+ rem running from TRUNK
+ call ..\..\..\src\bin\build.bat %*
+) else (
+ rem running from the distro
+ call ..\..\..\bin\build.bat %*
+)
+
+set "OVERRIDE_ANT_HOME="
Copied: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/build.sh (from rev 10288, branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover/build.sh)
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/build.sh (rev 0)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/build.sh 2011-03-04 14:40:28 UTC (rev 10289)
@@ -0,0 +1,15 @@
+#!/bin/sh
+
+OVERRIDE_ANT_HOME=../../../tools/ant
+export OVERRIDE_ANT_HOME
+
+if [ -f "../../../src/bin/build.sh" ]; then
+ # running from TRUNK
+ ../../../src/bin/build.sh "$@"
+else
+ # running from the distro
+ ../../../bin/build.sh "$@"
+fi
+
+
+
Copied: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/build.xml (from rev 10288, branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover/build.xml)
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/build.xml (rev 0)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/build.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -0,0 +1,111 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+ ~ Copyright 2009 Red Hat, Inc.
+ ~ Red Hat 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 default="run" name="HornetQ Java EE MDB with remote failover Config Example">
+
+ <import file="../common/build.xml"/>
+ <property file="../../common/config/server.properties"/>
+
+ <property name="example.live.server.dir" value="live-server"/>
+ <property name="example.backup.server.dir" value="backup-server"/>
+ <target name="run" depends="validate-jboss,compile">
+
+ <property name="serverclasspath" refid="jms.runtime.classpath"/>
+
+ <java classname="org.hornetq.javaee.example.MDBRemoteFailoverStaticClientExample" fork="true">
+ <jvmarg value="-Dhornetq.example.server.classpath=${serverclasspath}"/>
+ <jvmarg value="-Dhornetq.example.server.args=${server.args}"/>
+ <jvmarg value="-Dhornetq.example.logserveroutput=${hornetq.example.logserveroutput}"/>
+ <jvmarg value="-Dhornetq.example.runServer=${hornetq.example.runServer}"/>
+ <arg line="${hornetq.example.beans.file}"/>
+ <sysproperty key="java.library.path" value="${java.library.path}${path.separator}${aio.library.path}"/>
+ <classpath refid="jms.runtime.classpath"/>
+ </java>
+ </target>
+
+
+ <target name="copy-resources">
+ <copy todir="${example-profile}/deploy/jms-ra.rar/META-INF" overwrite="true">
+ <fileset dir="${example.server.dir}">
+ <include name="ra.xml"/>
+ </fileset>
+ </copy>
+ </target>
+
+ <target name="deployLive" depends="validate-jboss, copy-live-profile">
+ <property name="example-profile" value="${jboss.home}/server/${example.name}-live"/>
+ <copy todir="${example-profile}/deploy/hornetq" overwrite="true">
+ <fileset dir="${example.live.server.dir}"/>
+ </copy>
+ <exec dir="${jboss.home}/bin" executable="sh" osfamily="unix">
+ <arg line="run.sh -Djboss.service.binding.set=ports-01 -c ${example.name}-live"/>
+ </exec>
+ <exec dir="${jboss.home}/bin" executable="cmd" osfamily="windows">
+ <arg line="/c run.bat -Djboss.service.binding.set=ports-01 -c ${example.name}-live"/>
+ </exec>
+ </target>
+
+ <target name="copy-live-profile" depends="live.profile.check" unless="donot.copy.profile">
+ <property name="profile" value="${jboss.home}/server/default"/>
+ <property name="example-profile" value="${jboss.home}/server/${example.name}-live"/>
+ <property name="deploy.dir" value="${example-profile}/deploy/"/>
+ <mkdir dir="${example-profile}"/>
+ <copy todir="${example-profile}">
+ <fileset dir="${profile}">
+ <exclude name="**/*hornetq-configuration.xml"/>
+ <exclude name="**/*hornetq-jms.xml"/>
+ </fileset>
+ </copy>
+ </target>
+
+ <target name="live.profile.check">
+ <property name="example-profile" value="${jboss.home}/server/${example.name}-live"/>
+ <condition property="donot.copy.profile">
+ <available file="${example-profile}" type="dir"/>
+ </condition>
+ </target>
+
+ <target name="deployBackup" depends="validate-jboss, copy-backup-profile">
+ <property name="example-profile" value="${jboss.home}/server/${example.name}-backup"/>
+ <copy todir="${example-profile}/deploy/hornetq" overwrite="true">
+ <fileset dir="${example.backup.server.dir}"/>
+ </copy>
+ <exec dir="${jboss.home}/bin" executable="sh" osfamily="unix">
+ <arg line="run.sh -Djboss.service.binding.set=ports-02 -c ${example.name}-backup"/>
+ </exec>
+ <exec dir="${jboss.home}/bin" executable="cmd" osfamily="windows">
+ <arg line="/c run.bat -Djboss.service.binding.set=ports-02 -c ${example.name}-backup"/>
+ </exec>
+ </target>
+
+ <target name="copy-backup-profile" depends="backup.profile.check" unless="donot.copy.profile">
+ <property name="profile" value="${jboss.home}/server/default"/>
+ <property name="example-profile" value="${jboss.home}/server/${example.name}-backup"/>
+ <property name="deploy.dir" value="${example-profile}/deploy/"/>
+ <mkdir dir="${example-profile}"/>
+ <copy todir="${example-profile}">
+ <fileset dir="${profile}">
+ <exclude name="**/*hornetq-configuration.xml"/>
+ </fileset>
+ </copy>
+ </target>
+
+ <target name="backup.profile.check">
+ <property name="example-profile" value="${jboss.home}/server/${example.name}-backup"/>
+ <condition property="donot.copy.profile">
+ <available file="${example-profile}" type="dir"/>
+ </condition>
+ </target>
+
+</project>
\ No newline at end of file
Added: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/config/META-INF/application.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/config/META-INF/application.xml (rev 0)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/config/META-INF/application.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -0,0 +1,28 @@
+<!--
+ ~ Copyright 2009 Red Hat, Inc.
+ ~ Red Hat 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.
+ -->
+
+<application>
+ <display-name>My Application</display-name>
+
+ <module>
+ <web>
+ <web-uri>mdb-remote-failover-static-example.war</web-uri>
+ <context-root>/hornetq</context-root>
+ </web>
+ </module>
+ <module>
+ <java>mdb-remote-failover-static-example.jar</java>
+ </module>
+
+
+</application>
Added: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/config/ant.properties
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/config/ant.properties (rev 0)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/config/ant.properties 2011-03-04 14:40:28 UTC (rev 10289)
@@ -0,0 +1,14 @@
+#
+# Copyright 2009 Red Hat, Inc.
+# Red Hat 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.
+#
+
+example.name=mdb-remote-failover-static
\ No newline at end of file
Added: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/config/jndi.properties
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/config/jndi.properties (rev 0)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/config/jndi.properties 2011-03-04 14:40:28 UTC (rev 10289)
@@ -0,0 +1,16 @@
+#
+# Copyright 2009 Red Hat, Inc.
+# Red Hat 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.
+#
+
+java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory
+java.naming.provider.url=jnp://localhost:1199
+java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces
Added: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/live-server/hornetq-configuration.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/live-server/hornetq-configuration.xml (rev 0)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/live-server/hornetq-configuration.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -0,0 +1,109 @@
+<!--
+ ~ Copyright 2009 Red Hat, Inc.
+ ~ Red Hat 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="urn:hornetq"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="urn:hornetq /schema/hornetq-configuration.xsd">
+
+ <name>HornetQ.main.config</name>
+
+ <clustered>true</clustered>
+
+ <!--we shutdown the server process so need this set to true-->
+ <failover-on-shutdown>true</failover-on-shutdown>
+
+ <shared-store>true</shared-store>
+
+ <!--journal directories-->
+ <large-messages-directory>/tmp/shared/hornetq-data/large-messages</large-messages-directory>
+ <bindings-directory>/tmp/shared/hornetq-data/bindings</bindings-directory>
+ <journal-directory>/tmp/shared/hornetq-data/journal</journal-directory>
+ <paging-directory>/tmp/shared/hornetq-data/paging</paging-directory>
+
+ <!-- Connectors -->
+
+ <connectors>
+ <connector name="netty-connector">
+ <factory-class>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</factory-class>
+ <param key="host" value="${jboss.bind.address:localhost}"/>
+ <param key="port" value="${hornetq.remoting.netty.port:5445}"/>
+ </connector>
+
+ <connector name="in-vm">
+ <factory-class>org.hornetq.core.remoting.impl.invm.InVMConnectorFactory</factory-class>
+ <param key="server-id" value="${hornetq.server-id:0}"/>
+ </connector>
+ </connectors>
+
+ <!-- Acceptors -->
+ <acceptors>
+
+ <!-- In VM acceptor -->
+ <acceptor name="in-vm">
+ <factory-class>org.hornetq.core.remoting.impl.invm.InVMAcceptorFactory</factory-class>
+ <param key="server-id" value="${hornetq.server-id:0}"/>
+ </acceptor>
+ <acceptor name="netty-acceptor">
+ <factory-class>org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory</factory-class>
+ <param key="host" value="${jboss.bind.address:localhost}"/>
+ <param key="port" value="${hornetq.remoting.netty.port:5445}"/>
+ </acceptor>
+ </acceptors>
+
+ <broadcast-groups>
+ <broadcast-group name="bg-group1">
+ <group-address>231.7.7.7</group-address>
+ <group-port>9876</group-port>
+ <broadcast-period>1000</broadcast-period>
+ <connector-ref>netty-connector</connector-ref>
+ </broadcast-group>
+ </broadcast-groups>
+
+ <discovery-groups>
+ <discovery-group name="dg-group1">
+ <group-address>231.7.7.7</group-address>
+ <group-port>9876</group-port>
+ <refresh-timeout>60000</refresh-timeout>
+ </discovery-group>
+ </discovery-groups>
+
+ <cluster-connections>
+ <cluster-connection name="my-cluster">
+ <address>jms</address>
+ <connector-ref>netty-connector</connector-ref>
+ <discovery-group-ref discovery-group-name="dg-group1"/>
+ </cluster-connection>
+ </cluster-connections>
+ <!-- Other config -->
+
+ <security-settings>
+ <!--security for example queue-->
+ <security-setting match="jms.queue.inQueue">
+ <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-setting match="jms.queue.outQueue">
+ <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>
+
+</configuration>
Added: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/live-server/hornetq-jms.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/live-server/hornetq-jms.xml (rev 0)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/live-server/hornetq-jms.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -0,0 +1,49 @@
+<!--
+ ~ Copyright 2009 Red Hat, Inc.
+ ~ Red Hat 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="urn:hornetq"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd">
+ <!--the connection factory used by the example-->
+ <connection-factory name="ConnectionFactory">
+ <connectors>
+ <connector-ref connector-name="netty-connector"/>
+ </connectors>
+
+ <entries>
+ <entry name="ConnectionFactory"/>
+ </entries>
+
+ <ha>true</ha>
+ <!-- Pause 1 second between connect attempts -->
+ <retry-interval>1000</retry-interval>
+
+ <!-- Multiply subsequent reconnect pauses by this multiplier. This can be used to
+ implement an exponential back-off. For our purposes we just set to 1.0 so each reconnect
+ pause is the same length -->
+ <retry-interval-multiplier>1.0</retry-interval-multiplier>
+
+ <!-- Try reconnecting an unlimited number of times (-1 means "unlimited") -->
+ <reconnect-attempts>-1</reconnect-attempts>
+ </connection-factory>
+
+ <!--the queue used by the example-->
+ <queue name="inQueue">
+ <entry name="/queue/inQueue"/>
+ </queue>
+
+ <queue name="outQueue">
+ <entry name="/queue/outQueue"/>
+ </queue>
+
+</configuration>
Added: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/hornetq-configuration.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/hornetq-configuration.xml (rev 0)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/hornetq-configuration.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -0,0 +1,63 @@
+<!--
+ ~ Copyright 2009 Red Hat, Inc.
+ ~ Red Hat 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="urn:hornetq"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="urn:hornetq /schema/hornetq-configuration.xsd">
+
+ <name>HornetQ.main.config</name>
+
+ <bindings-directory>${jboss.server.data.dir}/messaging/bindings</bindings-directory>
+
+ <journal-directory>${jboss.server.data.dir}/messaging/journal</journal-directory>
+
+ <large-messages-directory>${jboss.server.data.dir}/messaging/largemessages</large-messages-directory>
+
+ <paging-directory>${jboss.server.data.dir}/messaging/paging</paging-directory>
+
+ <!-- Connectors -->
+ <connectors>
+ <connector name="netty">
+ <factory-class>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</factory-class>
+ </connector>
+
+ <connector name="in-vm">
+ <factory-class>org.hornetq.core.remoting.impl.invm.InVMConnectorFactory</factory-class>
+ </connector>
+
+ </connectors>
+
+ <!-- Acceptors -->
+ <acceptors>
+ <!-- In VM acceptor -->
+ <acceptor name="in-vm">
+ <factory-class>org.hornetq.core.remoting.impl.invm.InVMAcceptorFactory</factory-class>
+ <param key="server-id" value="0"/>
+ </acceptor>
+
+ <!-- Netty TCP Acceptor -->
+ <acceptor name="netty">
+ <factory-class>org.hornetq.core.remoting.impl.netty.NettyAcceptorFactory</factory-class>
+ <param key="port" value="${hornetq.remoting.netty.port:5445}"/>
+ </acceptor>
+ </acceptors>
+
+ <security-settings>
+ <security-setting match="jms.queue.#">
+ <permission type="consume" roles="guest,publisher"/>
+ <permission type="send" roles="guest,publisher"/>
+ </security-setting>
+ </security-settings>
+
+
+</configuration>
Added: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/hornetq-jms.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/hornetq-jms.xml (rev 0)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/hornetq-jms.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -0,0 +1,33 @@
+<!--
+ ~ Copyright 2009 Red Hat, Inc.
+ ~ Red Hat 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="urn:hornetq"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="urn:hornetq /schema/hornetq-jms.xsd">
+ <connection-factory name="ConnectionFactory">
+ <connectors>
+ <connector-ref connector-name="netty"/>
+ </connectors>
+ <entries>
+ <entry name="ConnectionFactory"/>
+ <entry name="XAConnectionFactory"/>
+ </entries>
+ </connection-factory>
+
+ <queue name="A">
+ <entry name="/queue/A"/>
+ </queue>
+ <queue name="B">
+ <entry name="/queue/B"/>
+ </queue>
+</configuration>
\ No newline at end of file
Added: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/jms-ds.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/jms-ds.xml (rev 0)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/jms-ds.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -0,0 +1,36 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+
+<!--
+ ~ Copyright 2009 Red Hat, Inc.
+ ~ Red Hat 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.
+ -->
+
+
+<!-- This file will be deployed by the target deploy on build.xml -->
+<connection-factories>
+
+
+ <!--
+ JMS XA Resource adapter, use this for outbound JMS connections.
+ Inbound connections are defined at the @MDB activaction or at the resource-adapter properties.
+ -->
+ <tx-connection-factory>
+ <jndi-name>RemoteJmsXA</jndi-name>
+ <xa-transaction/>
+ <rar-name>hornetq-ra.rar</rar-name>
+ <connection-definition>org.hornetq.ra.HornetQRAConnectionFactory</connection-definition>
+ <config-property name="SessionDefaultType" type="java.lang.String">javax.jms.Queue</config-property>
+ <config-property name="hA" type="java.lang.Boolean">true</config-property>
+ </tx-connection-factory>
+
+
+</connection-factories>
Added: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/ra.xml
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/ra.xml (rev 0)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/server/ra.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -0,0 +1,126 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<!--
+ ~ Copyright 2009 Red Hat, Inc.
+ ~ Red Hat 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.
+ -->
+
+<!-- This file will be installed by the example mdb-remote/build.xml, deploy target.
+ This is an example of how you could change the default configuration of a resource adapter
+ -->
+
+<connector xmlns="http://java.sun.com/xml/ns/j2ee"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee
+ http://java.sun.com/xml/ns/j2ee/connector_1_5.xsd"
+ version="1.5">
+
+ <description>HornetQ 2.0 Resource Adapter Alternate Configuration</description>
+ <display-name>HornetQ 2.0 Resource Adapter Alternate Configuration</display-name>
+
+ <vendor-name>Red Hat Middleware LLC</vendor-name>
+ <eis-type>JMS 1.1 Server</eis-type>
+ <resourceadapter-version>1.0</resourceadapter-version>
+
+ <license>
+ <description>
+Copyright 2009 Red Hat, Inc.
+ Red Hat 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.
+ </description>
+ <license-required>true</license-required>
+ </license>
+
+ <resourceadapter>
+ <config-property>
+ <description>
+ The transport type. Multiple connectors can be configured by using a comma separated list,
+ i.e. org.hornetq.core.remoting.impl.invm.InVMConnectorFactory,org.hornetq.core.remoting.impl.invm.InVMConnectorFactory.
+ </description>
+ <config-property-name>ConnectorClassName</config-property-name>
+ <config-property-type>java.lang.String</config-property-type>
+ <config-property-value>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory,org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</config-property-value>
+ </config-property>
+ <config-property>
+ <description>The transport configuration. These values must be in the form of key=val;key=val;,
+ if multiple connectors are used then each set must be separated by a comma i.e. host=host1;port=5445,host=host2;port=5446.
+ Each set of params maps to the connector classname specified.
+ </description>
+ <config-property-name>ConnectionParameters</config-property-name>
+ <config-property-type>java.lang.String</config-property-type>
+ <config-property-value>host=127.0.0.1;port=5445,host=127.0.0.1;port=5446</config-property-value>
+ </config-property>
+ <config-property>
+ <description>Do we support HA</description>
+ <config-property-name>hA</config-property-name>
+ <config-property-type>java.lang.Boolean</config-property-type>
+ <config-property-value>true</config-property-value>
+ </config-property>
+ <config-property>
+ <description>reconnect attempts</description>
+ <config-property-name>reconnectAttempts</config-property-name>
+ <config-property-type>java.lang.Integer</config-property-type>
+ <config-property-value>-1</config-property-value>
+ </config-property>
+
+ <outbound-resourceadapter>
+ <connection-definition>
+ <managedconnectionfactory-class>org.hornetq.ra.HornetQRAManagedConnectionFactory</managedconnectionfactory-class>
+
+ <config-property>
+ <description>The default session type</description>
+ <config-property-name>SessionDefaultType</config-property-name>
+ <config-property-type>java.lang.String</config-property-type>
+ <config-property-value>javax.jms.Queue</config-property-value>
+ </config-property>
+ <config-property>
+ <description>Try to obtain a lock within specified number of seconds; less than or equal to 0 disable this functionality</description>
+ <config-property-name>UseTryLock</config-property-name>
+ <config-property-type>java.lang.Integer</config-property-type>
+ <config-property-value>0</config-property-value>
+ </config-property>
+
+ <connectionfactory-interface>org.hornetq.ra.HornetQRAConnectionFactory</connectionfactory-interface>
+ <connectionfactory-impl-class>org.hornetq.ra.HornetQRAConnectionFactoryImpl</connectionfactory-impl-class>
+ <connection-interface>javax.jms.Session</connection-interface>
+ <connection-impl-class>org.hornetq.ra.HornetQRASession</connection-impl-class>
+ </connection-definition>
+ <transaction-support>XATransaction</transaction-support>
+ <authentication-mechanism>
+ <authentication-mechanism-type>BasicPassword</authentication-mechanism-type>
+ <credential-interface>javax.resource.spi.security.PasswordCredential</credential-interface>
+ </authentication-mechanism>
+ <reauthentication-support>false</reauthentication-support>
+ </outbound-resourceadapter>
+
+ <inbound-resourceadapter>
+ <messageadapter>
+ <messagelistener>
+ <messagelistener-type>javax.jms.MessageListener</messagelistener-type>
+ <activationspec>
+ <activationspec-class>org.hornetq.ra.inflow.HornetQActivationSpec</activationspec-class>
+ <required-config-property>
+ <config-property-name>destination</config-property-name>
+ </required-config-property>
+ </activationspec>
+ </messagelistener>
+ </messageadapter>
+ </inbound-resourceadapter>
+
+ </resourceadapter>
+</connector>
Copied: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/src/org/hornetq/javaee/example/MDBRemoteFailoverStaticClientExample.java (from rev 10288, branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover/src/org/hornetq/javaee/example/MDBRemoteFailoverClientExample.java)
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/src/org/hornetq/javaee/example/MDBRemoteFailoverStaticClientExample.java (rev 0)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/src/org/hornetq/javaee/example/MDBRemoteFailoverStaticClientExample.java 2011-03-04 14:40:28 UTC (rev 10289)
@@ -0,0 +1,106 @@
+/*
+ * Copyright 2009 Red Hat, Inc.
+ * Red Hat 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.hornetq.javaee.example;
+
+import javax.jms.*;
+import javax.naming.InitialContext;
+
+/**
+ * @author <a href="mailto:andy.taylor@jboss.com">Andy Taylor</a>
+ * Date: 2/24/11
+ * Time: 2:44 PM
+ */
+public class MDBRemoteFailoverStaticClientExample
+{
+ public static void main(String[] args) throws Exception
+ {
+ Connection connection = null;
+ InitialContext initialContext = null;
+ try
+ {
+ //Step 1. Create an initial context to perform the JNDI lookup.
+ initialContext = new InitialContext();
+
+ //Step 2. Perfom a lookup on the queue
+ Queue queue = (Queue) initialContext.lookup("/queue/inQueue");
+
+ //Step 3. Perform a lookup on the Connection Factory
+ ConnectionFactory cf = (ConnectionFactory) initialContext.lookup("/ConnectionFactory");
+
+ //Step 4.Create a JMS Connection
+ connection = cf.createConnection();
+
+ //Step 5. Create a JMS Session
+ Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+
+ //Step 6. Create a JMS Message Producer
+ MessageProducer producer = session.createProducer(queue);
+
+ //Step 7. Create a Text Message
+ TextMessage message = session.createTextMessage("This is a text message");
+
+ System.out.println("Sent message: " + message.getText());
+
+ //Step 8. Send the Message
+ producer.send(message);
+
+ //Step 15. We lookup the reply queue
+ queue = (Queue) initialContext.lookup("/queue/outQueue");
+
+ //Step 16. We create a JMS message consumer
+ MessageConsumer messageConsumer = session.createConsumer(queue);
+
+ //Step 17. We start the connedction so we can receive messages
+ connection.start();
+
+ //Step 18. We receive the message and print it out
+ message = (TextMessage) messageConsumer.receive(5000);
+
+ System.out.println("message.getText() = " + message.getText());
+
+ System.out.println("Kill Live Server and press enter");
+
+ System.in.read();
+
+ //Step 7. Create a Text Message
+ message = session.createTextMessage("This is another text message");
+
+ System.out.println("Sent message: " + message.getText());
+
+ //Step 8. Send the Message
+ producer.send(message);
+
+ //Step 16. We create a JMS message consumer
+ messageConsumer = session.createConsumer(queue);
+
+ //Step 18. We receive the message and print it out
+ message = (TextMessage) messageConsumer.receive(5000);
+
+ System.out.println("message.getText() = " + message.getText());
+
+ }
+ finally
+ {
+ //Step 19. Be sure to close our JMS resources!
+ if (initialContext != null)
+ {
+ initialContext.close();
+ }
+ if(connection != null)
+ {
+ connection.close();
+ }
+ }
+ }
+}
Copied: branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/src/org/hornetq/javaee/example/server/MDBRemoteFailoverStaticExample.java (from rev 10288, branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover/src/org/hornetq/javaee/example/server/MDBRemoteFailoverExample.java)
===================================================================
--- branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/src/org/hornetq/javaee/example/server/MDBRemoteFailoverStaticExample.java (rev 0)
+++ branches/Branch_2_2_EAP/examples/javaee/mdb-remote-failover-static/src/org/hornetq/javaee/example/server/MDBRemoteFailoverStaticExample.java 2011-03-04 14:40:28 UTC (rev 10289)
@@ -0,0 +1,90 @@
+/*
+ * Copyright 2009 Red Hat, Inc.
+ * Red Hat 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.hornetq.javaee.example.server;
+
+import org.hornetq.api.jms.HornetQJMSClient;
+import org.jboss.ejb3.annotation.ResourceAdapter;
+
+import javax.annotation.Resource;
+import javax.ejb.*;
+import javax.jms.*;
+
+/**
+ * @author <a href="mailto:andy.taylor@jboss.com">Andy Taylor</a>
+ * Date: 2/24/11
+ * Time: 2:44 PM
+ */
+@MessageDriven(name = "MDBRemoteFailoverExample",
+ activationConfig =
+ {
+ @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
+ @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/inQueue") ,
+ @ActivationConfigProperty(propertyName = "hA", propertyValue = "true")
+ })
+@TransactionManagement(value= TransactionManagementType.CONTAINER)
+@TransactionAttribute(value= TransactionAttributeType.REQUIRED)
+@ResourceAdapter("hornetq-ra.rar")
+public class MDBRemoteFailoverStaticExample implements MessageListener
+{
+
+ @Resource(mappedName = "java:RemoteJmsXA")
+ ConnectionFactory connectionFactory;
+ Queue replyQueue;
+
+ public void onMessage(Message message)
+ {
+ Connection conn = null;
+ try
+ {
+ replyQueue = HornetQJMSClient.createQueue("outQueue");
+ //Step 9. We know the client is sending a text message so we cast
+ TextMessage textMessage = (TextMessage)message;
+
+ //Step 10. get the text from the message.
+ String text = textMessage.getText();
+
+ System.out.println("message " + text);
+
+ //Step 11. we create a JMS connection
+ conn = connectionFactory.createConnection();
+
+ //Step 12. We create a JMS session
+ Session sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+
+ //Step 13. we create a producer for the reply queue
+ MessageProducer producer = sess.createProducer(replyQueue);
+
+ //Step 14. we create a message and send it
+ producer.send(sess.createTextMessage("this is a reply"));
+
+ }
+ catch (Exception e)
+ {
+ e.printStackTrace();
+ }
+ finally
+ {
+ if(conn != null)
+ {
+ try
+ {
+ conn.close();
+ }
+ catch (JMSException e)
+ {
+ }
+ }
+ }
+ }
+}
Modified: branches/Branch_2_2_EAP/src/config/jboss-as-4/clustered/ra.xml
===================================================================
--- branches/Branch_2_2_EAP/src/config/jboss-as-4/clustered/ra.xml 2011-03-03 23:51:36 UTC (rev 10288)
+++ branches/Branch_2_2_EAP/src/config/jboss-as-4/clustered/ra.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -47,13 +47,19 @@
<resourceadapter>
<resourceadapter-class>org.hornetq.ra.HornetQResourceAdapter</resourceadapter-class>
<config-property>
- <description>The transport type</description>
+ <description>
+ The transport type. Multiple connectors can be configured by using a comma separated list,
+ i.e. org.hornetq.core.remoting.impl.invm.InVMConnectorFactory,org.hornetq.core.remoting.impl.invm.InVMConnectorFactory.
+ </description>
<config-property-name>ConnectorClassName</config-property-name>
<config-property-type>java.lang.String</config-property-type>
<config-property-value>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</config-property-value>
</config-property>
<config-property>
- <description>The transport configuration. These values must be in the form of key=val;key=val;</description>
+ <description>The transport configuration. These values must be in the form of key=val;key=val;,
+ if multiple connectors are used then each set must be separated by a comma i.e. host=host1;port=5445,host=host2;port=5446.
+ Each set of params maps to the connector classname specified.
+ </description>
<config-property-name>ConnectionParameters</config-property-name>
<config-property-type>java.lang.String</config-property-type>
<config-property-value>host=localhost;port=5445</config-property-value>
Modified: branches/Branch_2_2_EAP/src/config/jboss-as-4/non-clustered/ra.xml
===================================================================
--- branches/Branch_2_2_EAP/src/config/jboss-as-4/non-clustered/ra.xml 2011-03-03 23:51:36 UTC (rev 10288)
+++ branches/Branch_2_2_EAP/src/config/jboss-as-4/non-clustered/ra.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -47,13 +47,19 @@
<resourceadapter>
<resourceadapter-class>org.hornetq.ra.HornetQResourceAdapter</resourceadapter-class>
<config-property>
- <description>The transport type</description>
+ <description>
+ The transport type. Multiple connectors can be configured by using a comma separated list,
+ i.e. org.hornetq.core.remoting.impl.invm.InVMConnectorFactory,org.hornetq.core.remoting.impl.invm.InVMConnectorFactory.
+ </description>
<config-property-name>ConnectorClassName</config-property-name>
<config-property-type>java.lang.String</config-property-type>
<config-property-value>org.hornetq.core.remoting.impl.netty.NettyConnectorFactory</config-property-value>
</config-property>
<config-property>
- <description>The transport configuration. These values must be in the form of key=val;key=val;</description>
+ <description>The transport configuration. These values must be in the form of key=val;key=val;,
+ if multiple connectors are used then each set must be separated by a comma i.e. host=host1;port=5445,host=host2;port=5446.
+ Each set of params maps to the connector classname specified.
+ </description>
<config-property-name>ConnectionParameters</config-property-name>
<config-property-type>java.lang.String</config-property-type>
<config-property-value>host=localhost;port=5445</config-property-value>
Modified: branches/Branch_2_2_EAP/src/config/ra.xml
===================================================================
--- branches/Branch_2_2_EAP/src/config/ra.xml 2011-03-03 23:51:36 UTC (rev 10288)
+++ branches/Branch_2_2_EAP/src/config/ra.xml 2011-03-04 14:40:28 UTC (rev 10289)
@@ -34,13 +34,19 @@
<resourceadapter>
<resourceadapter-class>org.hornetq.ra.HornetQResourceAdapter</resourceadapter-class>
<config-property>
- <description>The transport type</description>
+ <description>
+ The transport type. Multiple connectors can be configured by using a comma separated list,
+ i.e. org.hornetq.core.remoting.impl.invm.InVMConnectorFactory,org.hornetq.core.remoting.impl.invm.InVMConnectorFactory.
+ </description>
<config-property-name>ConnectorClassName</config-property-name>
<config-property-type>java.lang.String</config-property-type>
<config-property-value>org.hornetq.core.remoting.impl.invm.InVMConnectorFactory</config-property-value>
</config-property>
<config-property>
- <description>The transport configuration. These values must be in the form of key=val;key=val;</description>
+ <description>The transport configuration. These values must be in the form of key=val;key=val;,
+ if multiple connectors are used then each set must be separated by a comma i.e. host=host1;port=5445,host=host2;port=5446.
+ Each set of params maps to the connector classname specified.
+ </description>
<config-property-name>ConnectionParameters</config-property-name>
<config-property-type>java.lang.String</config-property-type>
<config-property-value>server-id=0</config-property-value>
Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/ra/ConnectionFactoryProperties.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/ra/ConnectionFactoryProperties.java 2011-03-03 23:51:36 UTC (rev 10288)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/ra/ConnectionFactoryProperties.java 2011-03-04 14:40:28 UTC (rev 10289)
@@ -12,6 +12,7 @@
*/
package org.hornetq.ra;
+import java.util.List;
import java.util.Map;
import org.hornetq.core.logging.Logger;
@@ -36,12 +37,12 @@
/**
* The transport type, changing the default configured from the RA
*/
- private String connectorClassName;
+ private List<String> connectorClassName;
/**
* The transport config, changing the default configured from the RA
*/
- private Map<String, Object> connectionParameters;
+ private List<Map<String, Object>> connectionParameters;
private Boolean ha;
@@ -102,23 +103,23 @@
/**
* @return the transportType
*/
- public String getConnectorClassName()
+ public List<String> getParsedConnectorClassNames()
{
return connectorClassName;
}
- public Map<String, Object> getParsedConnectionParameters()
+ public List<Map<String, Object>> getParsedConnectionParameters()
{
return connectionParameters;
}
- public void setParsedConnectionParameters(final Map<String, Object> connectionParameters)
+ public void setParsedConnectionParameters(final List<Map<String, Object>> connectionParameters)
{
this.connectionParameters = connectionParameters;
hasBeenUpdated = true;
}
- public void setConnectorClassName(final String value)
+ public void setParsedConnectorClassNames(final List<String> value)
{
connectorClassName = value;
hasBeenUpdated = true;
Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/ra/HornetQRAMCFProperties.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/ra/HornetQRAMCFProperties.java 2011-03-03 23:51:36 UTC (rev 10288)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/ra/HornetQRAMCFProperties.java 2011-03-04 14:40:28 UTC (rev 10289)
@@ -56,6 +56,9 @@
*/
private static final String TOPIC_TYPE = Topic.class.getName();
+
+ private String strConnectorClassName;
+
public String strConnectionParameters;
/**
@@ -96,6 +99,22 @@
return type;
}
+ public String getConnectorClassName()
+ {
+ return strConnectorClassName;
+ }
+
+ public void setConnectorClassName(final String connectorClassName)
+ {
+ if (HornetQRAMCFProperties.trace)
+ {
+ HornetQRAMCFProperties.log.trace("setConnectorClassName(" + connectorClassName + ")");
+ }
+
+ strConnectorClassName = connectorClassName;
+
+ setParsedConnectorClassNames(Util.parseConnectorConnectorConfig(connectorClassName));
+ }
/**
* @return the connectionParameters
*/
Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/ra/HornetQRAManagedConnectionFactory.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/ra/HornetQRAManagedConnectionFactory.java 2011-03-03 23:51:36 UTC (rev 10288)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/ra/HornetQRAManagedConnectionFactory.java 2011-03-04 14:40:28 UTC (rev 10289)
@@ -15,6 +15,7 @@
import java.io.PrintWriter;
import java.util.Iterator;
+import java.util.List;
import java.util.Set;
import javax.jms.ConnectionMetaData;
Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/ra/HornetQResourceAdapter.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/ra/HornetQResourceAdapter.java 2011-03-03 23:51:36 UTC (rev 10288)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/ra/HornetQResourceAdapter.java 2011-03-04 14:40:28 UTC (rev 10289)
@@ -14,6 +14,7 @@
import java.io.Serializable;
import java.util.HashMap;
+import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicBoolean;
@@ -82,7 +83,13 @@
*/
private String unparsedProperties;
+
/**
+ * The resource adapter connector classnames before parsing
+ */
+ private String unparsedConnectors;
+
+ /**
* Have the factory been configured
*/
private final AtomicBoolean configured;
@@ -242,13 +249,14 @@
{
HornetQResourceAdapter.log.trace("setTransportType(" + connectorClassName + ")");
}
+ unparsedConnectors = connectorClassName;
- raProperties.setConnectorClassName(connectorClassName);
+ raProperties.setParsedConnectorClassNames(Util.parseConnectorConnectorConfig(connectorClassName));
}
public String getConnectorClassName()
{
- return raProperties.getConnectorClassName();
+ return unparsedConnectors;
}
public String getConnectionParameters()
@@ -1344,12 +1352,12 @@
return defaultHornetQConnectionFactory;
}
- //TODO - currently RA only allows a single target server to be specified we should allow a list of servers to be passed in
public HornetQConnectionFactory createHornetQConnectionFactory(final ConnectionFactoryProperties overrideProperties)
{
HornetQConnectionFactory cf;
- String connectorClassName = overrideProperties.getConnectorClassName() != null ? overrideProperties.getConnectorClassName()
- : getConnectorClassName();
+ List<String> connectorClassName = overrideProperties.getParsedConnectorClassNames() != null ? overrideProperties.getParsedConnectorClassNames()
+ : raProperties.getParsedConnectorClassNames();
+
String discoveryAddress = overrideProperties.getDiscoveryAddress() != null ? overrideProperties.getDiscoveryAddress()
: getDiscoveryAddress();
@@ -1362,26 +1370,41 @@
if (connectorClassName != null)
{
- Map<String, Object> connectionParams;
- if(raProperties.getConnectorClassName().equals(overrideProperties.getConnectorClassName()))
+ TransportConfiguration[] transportConfigurations = new TransportConfiguration[connectorClassName.size()];
+
+ List<Map<String, Object>> connectionParams;
+ if(overrideProperties.getParsedConnectorClassNames() != null)
{
-
- connectionParams =
- overrideConnectionParameters(raProperties.getParsedConnectionParameters(),overrideProperties.getParsedConnectionParameters());
+ connectionParams = overrideProperties.getParsedConnectionParameters();
}
else
{
- connectionParams = overrideProperties.getParsedConnectionParameters();
+ connectionParams = raProperties.getParsedConnectionParameters();
}
- TransportConfiguration transportConf = new TransportConfiguration(connectorClassName, connectionParams);
+
+ for (int i = 0; i < connectorClassName.size(); i++)
+ {
+ TransportConfiguration tc;
+ if(connectionParams == null || i >= connectionParams.size())
+ {
+ tc = new TransportConfiguration(connectorClassName.get(i));
+ log.debug("No connector params provided using default");
+ }
+ else
+ {
+ tc = new TransportConfiguration(connectorClassName.get(i), connectionParams.get(i));
+ }
+
+ transportConfigurations[i] = tc;
+ }
if (ha)
{
- cf = HornetQJMSClient.createConnectionFactoryWithHA(JMSFactoryType.XA_CF, new TransportConfiguration[] {transportConf});
+ cf = HornetQJMSClient.createConnectionFactoryWithHA(JMSFactoryType.XA_CF, transportConfigurations);
}
else
{
- cf = HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.XA_CF, new TransportConfiguration[] {transportConf});
+ cf = HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.XA_CF, transportConfigurations);
}
}
else if (discoveryAddress != null)
Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/ra/Util.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/ra/Util.java 2011-03-03 23:51:36 UTC (rev 10288)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/ra/Util.java 2011-03-04 14:40:28 UTC (rev 10289)
@@ -13,7 +13,9 @@
package org.hornetq.ra;
import java.lang.reflect.Method;
+import java.util.ArrayList;
import java.util.HashMap;
+import java.util.List;
import java.util.Map;
import javax.naming.Context;
@@ -174,26 +176,49 @@
return context.lookup(name);
}
- public static Map<String, Object> parseConfig(final String config)
+ public static List<Map<String, Object>> parseConfig(final String config)
{
- HashMap<String, Object> result = new HashMap<String, Object>();
+ List<Map<String, Object>> result =new ArrayList<Map<String, Object>>();
- String elements[] = config.split(";");
+ String[] topElements = config.split(",");
- for (String element : elements)
+ for (String topElement : topElements)
{
- String expression[] = element.split("=");
+ HashMap<String, Object> map = new HashMap<String, Object>();
+ result.add(map);
- if (expression.length != 2)
+ String elements[] = topElement.split(";");
+
+ for (String element : elements)
{
- throw new IllegalArgumentException("Invalid expression " + element + " at " + config);
+ String expression[] = element.split("=");
+
+ if (expression.length != 2)
+ {
+ throw new IllegalArgumentException("Invalid expression " + element + " at " + config);
+ }
+
+ map.put(expression[0].trim(), expression[1].trim());
}
-
- result.put(expression[0].trim(), expression[1].trim());
}
+
return result;
}
+
+ public static List<String> parseConnectorConnectorConfig(String config)
+ {
+ List<String> res = new ArrayList<String>();
+
+ String[] elements = config.split(",");
+
+ for (String element : elements)
+ {
+ res.add(element.trim());
+ }
+
+ return res;
+ }
/** The Resource adapter can't depend on any provider's specific library. Because of that we use reflection to locate the
Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/ra/inflow/HornetQActivationSpec.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/ra/inflow/HornetQActivationSpec.java 2011-03-03 23:51:36 UTC (rev 10288)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/ra/inflow/HornetQActivationSpec.java 2011-03-04 14:40:28 UTC (rev 10289)
@@ -13,6 +13,7 @@
package org.hornetq.ra.inflow;
import java.util.HashMap;
+import java.util.List;
import java.util.Map;
import javax.jms.Session;
@@ -46,8 +47,7 @@
/** Whether trace is enabled */
private static boolean trace = HornetQActivationSpec.log.isTraceEnabled();
- /** The transport config, changing the default configured from the RA */
- private Map<String, Object> connectionParameters = new HashMap<String, Object>();
+ public String strConnectorClassName;
public String strConnectionParameters;
@@ -607,6 +607,23 @@
}
}
+ public String getConnectorClassName()
+ {
+ return strConnectorClassName;
+ }
+
+ public void setConnectorClassName(final String connectorClassName)
+ {
+ if (HornetQActivationSpec.trace)
+ {
+ HornetQActivationSpec.log.trace("setConnectorClassName(" + connectorClassName + ")");
+ }
+
+ strConnectorClassName = connectorClassName;
+
+ setParsedConnectorClassNames(Util.parseConnectorConnectorConfig(connectorClassName));
+ }
+
/**
* @return the connectionParameters
*/
@@ -615,16 +632,10 @@
return strConnectionParameters;
}
- @Override
- public Map<String, Object> getParsedConnectionParameters()
- {
- return connectionParameters;
- }
-
public void setConnectionParameters(final String configuration)
{
strConnectionParameters = configuration;
- connectionParameters = Util.parseConfig(configuration);
+ setParsedConnectionParameters(Util.parseConfig(configuration));
}
/**
Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/unit/ra/ResourceAdapterTest.java
===================================================================
--- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/unit/ra/ResourceAdapterTest.java 2011-03-03 23:51:36 UTC (rev 10288)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/unit/ra/ResourceAdapterTest.java 2011-03-04 14:40:28 UTC (rev 10289)
@@ -14,6 +14,9 @@
package org.hornetq.tests.unit.ra;
import java.lang.reflect.Method;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Map;
import java.util.Timer;
import javax.jms.Connection;
@@ -31,6 +34,7 @@
import junit.framework.Assert;
+import org.hornetq.api.core.TransportConfiguration;
import org.hornetq.api.core.client.ClientSession;
import org.hornetq.api.core.client.ClientSessionFactory;
import org.hornetq.api.core.client.HornetQClient;
@@ -269,7 +273,9 @@
HornetQResourceAdapter ra = new HornetQResourceAdapter();
ra.setConnectorClassName(InVMConnector.class.getName());
ConnectionFactoryProperties connectionFactoryProperties = new ConnectionFactoryProperties();
- connectionFactoryProperties.setConnectorClassName(NettyConnector.class.getName());
+ ArrayList<String> value = new ArrayList<String>();
+ value.add(NettyConnector.class.getName());
+ connectionFactoryProperties.setParsedConnectorClassNames(value);
HornetQConnectionFactory factory = ra.createHornetQConnectionFactory(connectionFactoryProperties);
HornetQConnectionFactory defaultFactory = ra.getDefaultHornetQConnectionFactory();
Assert.assertNotSame(factory, defaultFactory);
@@ -287,6 +293,105 @@
Assert.assertNotSame(factory, defaultFactory);
}
+ public void testCreateConnectionFactoryMultipleConnectors()
+ {
+ HornetQResourceAdapter ra = new HornetQResourceAdapter();
+ ra.setConnectorClassName(NETTY_CONNECTOR_FACTORY + "," + INVM_CONNECTOR_FACTORY + "," + NETTY_CONNECTOR_FACTORY);
+ HornetQConnectionFactory factory = ra.createHornetQConnectionFactory(new ConnectionFactoryProperties());
+ TransportConfiguration[] configurations = factory.getServerLocator().getStaticTransportConfigurations();
+ assertNotNull(configurations);
+ assertEquals(3, configurations.length);
+ assertEquals(NETTY_CONNECTOR_FACTORY, configurations[0].getFactoryClassName());
+ assertEquals(0, configurations[0].getParams().size());
+ assertEquals(INVM_CONNECTOR_FACTORY, configurations[1].getFactoryClassName());
+ assertEquals(0, configurations[1].getParams().size());
+ assertEquals(NETTY_CONNECTOR_FACTORY, configurations[2].getFactoryClassName());
+ assertEquals(0, configurations[2].getParams().size());
+ }
+
+ public void testCreateConnectionFactoryMultipleConnectorsAndParams()
+ {
+ HornetQResourceAdapter ra = new HornetQResourceAdapter();
+ ra.setConnectorClassName(NETTY_CONNECTOR_FACTORY + "," + INVM_CONNECTOR_FACTORY + "," + NETTY_CONNECTOR_FACTORY);
+ ra.setConnectionParameters("host=host1;port=5445, serverid=0, host=host2;port=5446");
+ HornetQConnectionFactory factory = ra.createHornetQConnectionFactory(new ConnectionFactoryProperties());
+ TransportConfiguration[] configurations = factory.getServerLocator().getStaticTransportConfigurations();
+ assertNotNull(configurations);
+ assertEquals(3, configurations.length);
+ assertEquals(NETTY_CONNECTOR_FACTORY, configurations[0].getFactoryClassName());
+ assertEquals(2, configurations[0].getParams().size());
+ assertEquals("host1", configurations[0].getParams().get("host"));
+ assertEquals("5445", configurations[0].getParams().get("port"));
+ assertEquals(INVM_CONNECTOR_FACTORY, configurations[1].getFactoryClassName());
+ assertEquals(1, configurations[1].getParams().size());
+ assertEquals("0", configurations[1].getParams().get("serverid"));
+ assertEquals(NETTY_CONNECTOR_FACTORY, configurations[2].getFactoryClassName());
+ assertEquals(2, configurations[2].getParams().size());
+ assertEquals("host2", configurations[2].getParams().get("host"));
+ assertEquals("5446", configurations[2].getParams().get("port"));
+ }
+
+ public void testCreateConnectionFactoryMultipleConnectorsOverride()
+ {
+ HornetQResourceAdapter ra = new HornetQResourceAdapter();
+ ra.setConnectorClassName(NETTY_CONNECTOR_FACTORY + "," + INVM_CONNECTOR_FACTORY + "," + NETTY_CONNECTOR_FACTORY);
+ ConnectionFactoryProperties overrideProperties = new ConnectionFactoryProperties();
+ ArrayList<String> value = new ArrayList<String>();
+ value.add(INVM_CONNECTOR_FACTORY);
+ value.add(NETTY_CONNECTOR_FACTORY);
+ value.add(INVM_CONNECTOR_FACTORY);
+ overrideProperties.setParsedConnectorClassNames(value);
+ HornetQConnectionFactory factory = ra.createHornetQConnectionFactory(overrideProperties);
+ TransportConfiguration[] configurations = factory.getServerLocator().getStaticTransportConfigurations();
+ assertNotNull(configurations);
+ assertEquals(3, configurations.length);
+ assertEquals(INVM_CONNECTOR_FACTORY, configurations[0].getFactoryClassName());
+ assertEquals(0, configurations[0].getParams().size());
+ assertEquals(NETTY_CONNECTOR_FACTORY, configurations[1].getFactoryClassName());
+ assertEquals(0, configurations[1].getParams().size());
+ assertEquals(INVM_CONNECTOR_FACTORY, configurations[2].getFactoryClassName());
+ assertEquals(0, configurations[2].getParams().size());
+ }
+
+ public void testCreateConnectionFactoryMultipleConnectorsOverrideAndParams()
+ {
+ HornetQResourceAdapter ra = new HornetQResourceAdapter();
+ ra.setConnectorClassName(NETTY_CONNECTOR_FACTORY + "," + INVM_CONNECTOR_FACTORY + "," + NETTY_CONNECTOR_FACTORY);
+ ra.setConnectionParameters("host=host1;port=5445, serverid=0, host=host2;port=5446");
+ ConnectionFactoryProperties overrideProperties = new ConnectionFactoryProperties();
+ ArrayList<String> value = new ArrayList<String>();
+ value.add(INVM_CONNECTOR_FACTORY);
+ value.add(NETTY_CONNECTOR_FACTORY);
+ value.add(INVM_CONNECTOR_FACTORY);
+ overrideProperties.setParsedConnectorClassNames(value);
+ ArrayList<Map<String, Object>> connectionParameters = new ArrayList<Map<String, Object>>();
+ Map<String, Object> map1 = new HashMap<String, Object>();
+ map1.put("serverid", "0");
+ connectionParameters.add(map1);
+ Map<String, Object> map2 = new HashMap<String, Object>();
+ map2.put("host", "myhost");
+ map2.put("port", "5445");
+ connectionParameters.add(map2);
+ Map<String, Object> map3 = new HashMap<String, Object>();
+ map3.put("serverid", "1");
+ connectionParameters.add(map3);
+ overrideProperties.setParsedConnectionParameters(connectionParameters);
+ HornetQConnectionFactory factory = ra.createHornetQConnectionFactory(overrideProperties);
+ TransportConfiguration[] configurations = factory.getServerLocator().getStaticTransportConfigurations();
+ assertNotNull(configurations);
+ assertEquals(3, configurations.length);
+ assertEquals(INVM_CONNECTOR_FACTORY, configurations[0].getFactoryClassName());
+ assertEquals(1, configurations[0].getParams().size());
+ assertEquals("0", configurations[0].getParams().get("serverid"));
+ assertEquals(NETTY_CONNECTOR_FACTORY, configurations[1].getFactoryClassName());
+ assertEquals(2, configurations[1].getParams().size());
+ assertEquals("myhost", configurations[1].getParams().get("host"));
+ assertEquals("5445", configurations[1].getParams().get("port"));
+ assertEquals(INVM_CONNECTOR_FACTORY, configurations[2].getFactoryClassName());
+ assertEquals(1, configurations[2].getParams().size());
+ assertEquals("1", configurations[2].getParams().get("serverid"));
+ }
+
public void testCreateConnectionFactoryThrowsException() throws Exception
{
HornetQResourceAdapter ra = new HornetQResourceAdapter();
14 years, 9 months
- 1
- 0
JBoss hornetq SVN: r10288 - branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/security.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2011-03-03 18:51:36 -0500 (Thu, 03 Mar 2011)
New Revision: 10288
Modified:
branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/security/NettySecurityClientTest.java
Log:
Adding logs to a security test
Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/security/NettySecurityClientTest.java
===================================================================
--- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/security/NettySecurityClientTest.java 2011-03-03 23:51:02 UTC (rev 10287)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/security/NettySecurityClientTest.java 2011-03-03 23:51:36 UTC (rev 10288)
@@ -104,15 +104,19 @@
// spawn a JVM that creates a client withor without a security manager which sends and receives a test message
Process p = SpawnedVMSupport.spawnVM(SimpleClient.class.getName(),
+ "-Xms512m -Xmx512m ",
vmargs,
false,
+ true,
new String[] { NettyConnectorFactory.class.getName() });
InputStreamReader isr = new InputStreamReader(p.getInputStream());
+
BufferedReader br = new BufferedReader(isr);
String line = null;
while ((line = br.readLine()) != null)
{
+ //System.out.println(line);
line = line.replace('|', '\n');
if (line.startsWith("Listening"))
{
14 years, 9 months
- 1
- 0
JBoss hornetq SVN: r10287 - branches/Branch_2_2_EAP/src/main/org/hornetq/utils.
by do-not-reply＠jboss.org
Author: clebert.suconic(a)jboss.com
Date: 2011-03-03 18:51:02 -0500 (Thu, 03 Mar 2011)
New Revision: 10287
Modified:
branches/Branch_2_2_EAP/src/main/org/hornetq/utils/VersionLoader.java
Log:
Fixing a test
Modified: branches/Branch_2_2_EAP/src/main/org/hornetq/utils/VersionLoader.java
===================================================================
--- branches/Branch_2_2_EAP/src/main/org/hornetq/utils/VersionLoader.java 2011-03-03 23:15:11 UTC (rev 10286)
+++ branches/Branch_2_2_EAP/src/main/org/hornetq/utils/VersionLoader.java 2011-03-03 23:51:02 UTC (rev 10287)
@@ -15,9 +15,12 @@
import java.io.IOException;
import java.io.InputStream;
+import java.security.AccessController;
+import java.security.PrivilegedAction;
import java.util.Properties;
import java.util.StringTokenizer;
+import org.hornetq.core.client.impl.ClientSessionFactoryImpl;
import org.hornetq.core.logging.Logger;
import org.hornetq.core.version.Version;
import org.hornetq.core.version.impl.VersionImpl;
@@ -35,20 +38,36 @@
private static final Logger log = Logger.getLogger(VersionLoader.class);
public static final String VERSION_PROP_FILE_KEY = "hornetq.version.property.filename";
-
+
public static final String DEFAULT_PROP_FILE_NAME = "hornetq-version.properties";
private static String PROP_FILE_NAME;
-
+
private static Version version;
static
{
try
{
- PROP_FILE_NAME = System.getProperty(VersionLoader.VERSION_PROP_FILE_KEY);
- if(PROP_FILE_NAME == null)
+
+ try
{
+ PROP_FILE_NAME = AccessController.doPrivileged(new PrivilegedAction<String>()
+ {
+ public String run()
+ {
+ return System.getProperty(VersionLoader.VERSION_PROP_FILE_KEY);
+ }
+ });
+ }
+ catch (Throwable e)
+ {
+ log.warn(e.getMessage(), e);
+ PROP_FILE_NAME = null;
+ }
+
+ if (PROP_FILE_NAME == null)
+ {
PROP_FILE_NAME = VersionLoader.DEFAULT_PROP_FILE_NAME;
}
@@ -93,7 +112,7 @@
String versionSuffix = versionProps.getProperty("hornetq.version.versionSuffix");
String nettyVersion = versionProps.getProperty("hornetq.netty.version");
int[] compatibleVersionArray = parseCompatibleVersionList(versionProps.getProperty("hornetq.version.compatibleVersionList"));
-
+
return new VersionImpl(versionName,
majorVersion,
minorVersion,
@@ -126,39 +145,39 @@
private static int[] parseCompatibleVersionList(String property) throws IOException
{
int[] verArray = new int[0];
- StringTokenizer tokenizer = new StringTokenizer(property,",");
- while(tokenizer.hasMoreTokens())
+ StringTokenizer tokenizer = new StringTokenizer(property, ",");
+ while (tokenizer.hasMoreTokens())
{
int from = -1, to = -1;
String token = tokenizer.nextToken();
-
+
int cursor = 0;
char firstChar = token.charAt(0);
- if(firstChar == '-')
+ if (firstChar == '-')
{
// "-n" pattern
from = 0;
cursor++;
- for(;cursor < token.length() && Character.isDigit(token.charAt(cursor)); cursor++);
- if(cursor > 1)
+ for (; cursor < token.length() && Character.isDigit(token.charAt(cursor)); cursor++);
+ if (cursor > 1)
{
to = Integer.parseInt(token.substring(1, cursor));
}
}
- else if(Character.isDigit(firstChar))
+ else if (Character.isDigit(firstChar))
{
- for(;cursor < token.length() && Character.isDigit(token.charAt(cursor)); cursor++);
+ for (; cursor < token.length() && Character.isDigit(token.charAt(cursor)); cursor++);
from = Integer.parseInt(token.substring(0, cursor));
-
- if(cursor == token.length())
+
+ if (cursor == token.length())
{
// just "n" pattern
to = from;
}
- else if(token.charAt(cursor)== '-')
+ else if (token.charAt(cursor) == '-')
{
cursor++;
- if(cursor == token.length())
+ if (cursor == token.length())
{
// "n-" pattern
to = Integer.MAX_VALUE;
@@ -171,19 +190,19 @@
}
}
- if(from != -1 && to != -1)
+ if (from != -1 && to != -1)
{
// merge version array
- int[] newArray = new int[verArray.length + to-from+1];
+ int[] newArray = new int[verArray.length + to - from + 1];
System.arraycopy(verArray, 0, newArray, 0, verArray.length);
- for(int i=0; i<to-from+1; i++)
+ for (int i = 0; i < to - from + 1; i++)
{
- newArray[verArray.length+i] = from + i;
+ newArray[verArray.length + i] = from + i;
}
verArray = newArray;
}
}
-
+
return verArray;
}
}
14 years, 9 months
- 1
- 0