fixed examples and some docs after Artemis renaming
This commit is contained in:
parent
c65bec5484
commit
efbe4e621f
|
@ -462,7 +462,7 @@ If you're using JMS and you're using JNDI on the client to look up your
|
|||
JMS connection factory instances then you can specify these parameters
|
||||
in the JNDI context environment in, e.g. `jndi.properties`:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.myConnectionFactory=(tcp://myhost:61616,tcp://myhost2:61616)
|
||||
|
||||
The `connectionFactory.myConnectionFactory` contains a list of servers to use for the
|
||||
|
@ -843,7 +843,7 @@ JMS connection factory instances then you can specify these parameters
|
|||
in the JNDI context environment in, e.g. `jndi.properties`, to specify
|
||||
the load balancing policy directly:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connection.myConnectionFactory=tcp://localhost:61616?loadBalancingPolicyClassName=org.apache.activemq.api.core.client.loadbalance.RandomConnectionLoadBalancingPolicy
|
||||
|
||||
The above example would instantiate a JMS connection factory that uses
|
||||
|
|
|
@ -77,7 +77,7 @@ couple of reasons for this:
|
|||
`java.naming.provider.url` to construct the transport. Here's a
|
||||
simple example:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.MyConnectionFactory=tcp://myhost:61616
|
||||
|
||||
## Configuring the transport directly from the client side.
|
||||
|
|
|
@ -101,7 +101,7 @@ environment, e.g. `jndi.properties`. Here's a simple example using the
|
|||
"ConnectionFactory" connection factory which is available in the context
|
||||
by default:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.myConnectionFactory=tcp://localhost:61616?consumerWindowSize=0
|
||||
|
||||
If the connection factory is directly instantiated, the consumer window
|
||||
|
@ -138,7 +138,7 @@ max rate can be configured in the JNDI context environment, e.g.
|
|||
`jndi.properties`. Here's a simple example using the "ConnectionFactory"
|
||||
connection factory which is available in the context by default:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
java.naming.provider.url=tcp://localhost:61616?consumerMaxRate=10
|
||||
|
||||
If the connection factory is directly instantiated, the max rate size
|
||||
|
@ -191,7 +191,7 @@ e.g. `jndi.properties`. Here's a simple example using the
|
|||
"ConnectionFactory" connection factory which is available in the context
|
||||
by default:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.myConnectionFactory=tcp://localhost:61616?producerWindowSize=10
|
||||
|
||||
If the connection factory is directly instantiated, the producer window
|
||||
|
@ -285,7 +285,7 @@ max rate size can be configured in the JNDI context environment, e.g.
|
|||
`jndi.properties`. Here's a simple example using the "ConnectionFactory"
|
||||
connection factory which is available in the context by default:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.myConnectionFactory=tcp://localhost:61616?producerMaxRate=10
|
||||
|
||||
If the connection factory is directly instantiated, the max rate size
|
||||
|
|
|
@ -227,7 +227,7 @@ it is using JNDI.
|
|||
Stomp requires the file `jndi.properties` to be available on the
|
||||
classpath. This should look something like:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
|
||||
Configure any required JNDI resources in this file according to the
|
||||
documentation.
|
||||
|
|
|
@ -85,7 +85,7 @@ environment, e.g. `jndi.properties`. Here's a simple example using the
|
|||
"ConnectionFactory" connection factory which is available in the context
|
||||
by default:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.myConnectionFactory=tcp://localhost:61616?minLargeMessageSize=250000
|
||||
|
||||
|
||||
|
@ -120,7 +120,7 @@ e.g. `jndi.properties`. Here's a simple example using the
|
|||
"ConnectionFactory" connection factory which is available in the context
|
||||
by default:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.myConnectionFactory=tcp://localhost:61616?compressLargeMessages=true
|
||||
|
||||
## Streaming large messages
|
||||
|
|
|
@ -67,7 +67,7 @@ also be set in the JNDI context environment, e.g. `jndi.properties`.
|
|||
Here's a simple example using the "ConnectionFactory" connection factory
|
||||
which is available in the context by default
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.myConnectionFactory=tcp://localhost:61616?autoGroup=true
|
||||
|
||||
Alternatively you can set the group id via the connection factory. All
|
||||
|
@ -77,7 +77,7 @@ can also be set in the JNDI context environment, e.g. `jndi.properties`.
|
|||
Here's a simple example using the "ConnectionFactory" connection factory
|
||||
which is available in the context by default:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.myConnectionFactory=tcp://localhost:61616?roupID=Group-0
|
||||
|
||||
## Example
|
||||
|
|
|
@ -45,7 +45,7 @@ arrive soon, overriding the previous price.
|
|||
This can be configured in a client's JNDI context environment, e.g.
|
||||
`jndi.properties`, like this:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connection.ConnectionFactory=tcp://localhost:61616?preAcknowledge=true
|
||||
|
||||
Alternatively, to use pre-acknowledgement mode using the JMS API, create
|
||||
|
|
|
@ -149,7 +149,7 @@ environment, e.g. `jndi.properties`. Here's a simple example using the
|
|||
"ConnectionFactory" connection factory which is available in the context
|
||||
by default:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
|
||||
java.naming.provider.url=tcp://localhost:61616
|
||||
|
||||
|
|
|
@ -68,7 +68,7 @@ Here's a simple example of the JNDI context environment for a client
|
|||
looking up a connection factory to access an *embedded* instance of
|
||||
Apache ActiveMQ Artemis:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.invmConnectionFactory=vm://0
|
||||
|
||||
In this instance we have created a connection factory that is bound to
|
||||
|
@ -81,7 +81,7 @@ have an InVM acceptor with a unique server-ID. A client using JMS and
|
|||
JNDI can account for this by specifying a connction factory for each
|
||||
server, like so:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.invmConnectionFactory0=vm://0
|
||||
connectionFactory.invmConnectionFactory1=vm://1
|
||||
connectionFactory.invmConnectionFactory2=vm://2
|
||||
|
@ -101,7 +101,7 @@ most commonly connect across a network a remote broker. Here's a simple
|
|||
example of a client configuring a connection factory to connect to a
|
||||
remote broker running on myhost:5445:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://myhost:5445
|
||||
|
||||
In the example above the client is using the `tcp` scheme for the
|
||||
|
@ -180,7 +180,7 @@ are supported just like with `udp`.
|
|||
The default type for the default connection factory is of type `javax.jms.ConnectionFactory`.
|
||||
This can be changed by setting the type like so
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
java.naming.provider.url=tcp://localhost:5445?type=CF
|
||||
|
||||
In this example it is still set to the default, below shows a list of types that can be set.
|
||||
|
@ -211,7 +211,7 @@ like so:
|
|||
And if the client wanted to bind this queue to "queues/OrderQueue" then
|
||||
the JNDI properties would be configured like so:
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
java.naming.provider.url=tcp://myhost:5445
|
||||
queue.queues/OrderQueue=OrderQueue
|
||||
|
||||
|
|
|
@ -90,7 +90,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.AerogearExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.AerogearExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
</args>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
|
|
|
@ -78,7 +78,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ApplicationLayerFailoverExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ApplicationLayerFailoverExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:61617</param>
|
||||
|
|
|
@ -151,7 +151,7 @@ public class ApplicationLayerFailoverExample extends ActiveMQExample
|
|||
{
|
||||
// Step 1. Get an initial context for looking up JNDI from the server
|
||||
Hashtable<String, Object> properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", "tcp://127.0.0.1:" + (61616 + server));
|
||||
properties.put("queue.queue/exampleQueue", "exampleQueue");
|
||||
initialContext = new InitialContext(properties);
|
||||
|
|
|
@ -15,4 +15,4 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
server.args=-XX:+UseParallelGC -Xms256M -Xmx256M -XX:+AggressiveOpts -XX:+UseFastAccessorMethods -Dcom.sun.management.jmxremote -Djava.util.logging.config.file=${imported.basedir}/config/logging.properties -Djava.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
server.args=-XX:+UseParallelGC -Xms256M -Xmx256M -XX:+AggressiveOpts -XX:+UseFastAccessorMethods -Dcom.sun.management.jmxremote -Djava.util.logging.config.file=${imported.basedir}/config/logging.properties -Djava.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
|
|
|
@ -82,7 +82,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.BridgeExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.BridgeExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:61617</param>
|
||||
|
|
|
@ -61,7 +61,7 @@ under the License.
|
|||
<queue-name>jms.queue.sausage-factory</queue-name>
|
||||
<forwarding-address>jms.queue.mincing-machine</forwarding-address>
|
||||
<filter string="name='aardvark'"/>
|
||||
<transformer-class-name>org.apache.activemq.jms.example.HatColourChangeTransformer</transformer-class-name>
|
||||
<transformer-class-name>org.apache.activemq.artemis.jms.example.HatColourChangeTransformer</transformer-class-name>
|
||||
<reconnect-attempts>-1</reconnect-attempts>
|
||||
<static-connectors>
|
||||
<connector-ref>remote-connector</connector-ref>
|
||||
|
|
|
@ -56,7 +56,7 @@ public class BridgeExample extends ActiveMQExample
|
|||
// Step 1 - we create an initial context for looking up JNDI on node 0
|
||||
|
||||
Hashtable<String, Object> properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", "tcp://127.0.0.1:61616");
|
||||
properties.put("queue.queue/sausage-factory", "sausage-factory");
|
||||
ic0 = new InitialContext(properties);
|
||||
|
@ -72,7 +72,7 @@ public class BridgeExample extends ActiveMQExample
|
|||
// Step 4 - we create an initial context for looking up JNDI on node 1
|
||||
|
||||
properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", "tcp://127.0.0.1:61617");
|
||||
properties.put("queue.queue/mincing-machine", "mincing-machine");
|
||||
ic1 = new InitialContext(properties);
|
||||
|
|
|
@ -62,7 +62,7 @@ under the License.
|
|||
<queue-name>jms.queue.sausage-factory</queue-name>
|
||||
<forwarding-address>jms.queue.mincing-machine</forwarding-address>
|
||||
<filter string="name='aardvark'"/>
|
||||
<transformer-class-name>org.apache.activemq.jms.example.HatColourChangeTransformer</transformer-class-name>
|
||||
<transformer-class-name>org.apache.activemq.artemis.jms.example.HatColourChangeTransformer</transformer-class-name>
|
||||
<reconnect-attempts>-1</reconnect-attempts>
|
||||
<static-connectors>
|
||||
<connector-ref>remote-connector</connector-ref>
|
||||
|
|
|
@ -64,7 +64,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.QueueBrowserExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.QueueBrowserExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
</args>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
|
|
|
@ -95,7 +95,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ClientKickoffExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ClientKickoffExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
</args>
|
||||
|
|
|
@ -116,9 +116,9 @@ under the License.
|
|||
|
||||
<p>Warnings be displayed on the server output:</p>
|
||||
<pre class="prettyprint">
|
||||
<code>org.apache.activemq.jms.example.SpawnedJMSServer out:11:22:33,034 WARN @RMI TCP Connection(3)-192.168.0.10 [RemotingConnectionImpl] Connection failure has been detected connections for /192.168.0.10:52707 closed by management:0
|
||||
org.apache.activemq.jms.example.SpawnedJMSServer out:11:22:33,035 WARN @RMI TCP Connection(3)-192.168.0.10 [ServerSessionImpl] Client connection failed, clearing up resources for session 4646da35-2fe8-11de-9ce9-752ccc2b26e4
|
||||
org.apache.activemq.jms.example.SpawnedJMSServer out:11:22:33,035 WARN @RMI TCP Connection(3)-192.168.0.10 [ServerSessionImpl] Cleared up resources for session 4646da35-2fe8-11de-9ce9-752ccc2b26e4
|
||||
<code>org.apache.activemq.artemis.jms.example.SpawnedJMSServer out:11:22:33,034 WARN @RMI TCP Connection(3)-192.168.0.10 [RemotingConnectionImpl] Connection failure has been detected connections for /192.168.0.10:52707 closed by management:0
|
||||
org.apache.activemq.artemis.jms.example.SpawnedJMSServer out:11:22:33,035 WARN @RMI TCP Connection(3)-192.168.0.10 [ServerSessionImpl] Client connection failed, clearing up resources for session 4646da35-2fe8-11de-9ce9-752ccc2b26e4
|
||||
org.apache.activemq.artemis.jms.example.SpawnedJMSServer out:11:22:33,035 WARN @RMI TCP Connection(3)-192.168.0.10 [ServerSessionImpl] Cleared up resources for session 4646da35-2fe8-11de-9ce9-752ccc2b26e4
|
||||
</code>
|
||||
</pre>
|
||||
|
||||
|
|
|
@ -15,5 +15,5 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
|
|
|
@ -98,7 +98,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ClientSideFailoverListerExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ClientSideFailoverListerExample</clientClass>
|
||||
<systemProperties>
|
||||
<property>
|
||||
<name>exampleConfigDir</name>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616?ha=true&retryInterval=1000&retryIntervalMultiplier=1.0&reconnectAttempts=-1
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
|
|
|
@ -109,7 +109,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ClientSideLoadBalancingExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ClientSideLoadBalancingExample</clientClass>
|
||||
<systemProperties>
|
||||
<property>
|
||||
<name>exampleConfigDir</name>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=udp://231.7.7.7:9876
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
|
|
|
@ -89,7 +89,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ClusteredDurableSubscriptionExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ClusteredDurableSubscriptionExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:61617</param>
|
||||
|
|
|
@ -57,7 +57,7 @@ public class ClusteredDurableSubscriptionExample extends ActiveMQExample
|
|||
{
|
||||
// Step 1. Get an initial context for looking up JNDI from server 0
|
||||
Hashtable<String, Object> properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[0]);
|
||||
properties.put("topic.topic/exampleTopic", "exampleTopic");
|
||||
ic0 = new InitialContext(properties);
|
||||
|
@ -71,7 +71,7 @@ public class ClusteredDurableSubscriptionExample extends ActiveMQExample
|
|||
// Step 4. Get an initial context for looking up JNDI from server 1
|
||||
|
||||
properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[1]);
|
||||
ic1 = new InitialContext(properties);
|
||||
|
||||
|
|
|
@ -117,7 +117,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ClusteredGroupingExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ClusteredGroupingExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:61617</param>
|
||||
|
|
|
@ -59,7 +59,7 @@ public class ClusteredGroupingExample extends ActiveMQExample
|
|||
{
|
||||
// Step 1. Get an initial context for looking up JNDI from server 0
|
||||
Hashtable<String, Object> properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[0]);
|
||||
properties.put("queue.queue/exampleQueue", "exampleQueue");
|
||||
ic0 = new InitialContext(properties);
|
||||
|
@ -72,7 +72,7 @@ public class ClusteredGroupingExample extends ActiveMQExample
|
|||
|
||||
// Step 4. Get an initial context for looking up JNDI from server 1
|
||||
properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[1]);
|
||||
ic1 = new InitialContext(properties);
|
||||
|
||||
|
@ -81,7 +81,7 @@ public class ClusteredGroupingExample extends ActiveMQExample
|
|||
|
||||
// Step 4. Get an initial context for looking up JNDI from server 2
|
||||
properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[2]);
|
||||
ic2 = new InitialContext(properties);
|
||||
|
||||
|
|
|
@ -93,7 +93,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ClusteredJgroupsExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ClusteredJgroupsExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:61617</param>
|
||||
|
|
|
@ -54,7 +54,7 @@ public class ClusteredJgroupsExample extends ActiveMQExample
|
|||
{
|
||||
// Step 1. Get an initial context for looking up JNDI from server 0
|
||||
Hashtable<String, Object> properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[0]);
|
||||
properties.put("queue.queue/exampleQueue", "exampleQueue");
|
||||
ic0 = new InitialContext(properties);
|
||||
|
@ -67,7 +67,7 @@ public class ClusteredJgroupsExample extends ActiveMQExample
|
|||
|
||||
// Step 4. Get an initial context for looking up JNDI from server 1
|
||||
properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[1]);
|
||||
ic1 = new InitialContext(properties);
|
||||
|
||||
|
|
|
@ -15,5 +15,5 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
|
|
|
@ -15,5 +15,5 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
java.naming.provider.url=tcp://localhost:61617
|
||||
|
|
|
@ -89,7 +89,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ClusteredQueueExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ClusteredQueueExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:61617</param>
|
||||
|
|
|
@ -55,7 +55,7 @@ public class ClusteredQueueExample extends ActiveMQExample
|
|||
{
|
||||
// Step 1. Get an initial context for looking up JNDI from server 0
|
||||
Hashtable<String, Object> properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[0]);
|
||||
properties.put("queue.queue/exampleQueue", "exampleQueue");
|
||||
ic0 = new InitialContext(properties);
|
||||
|
@ -68,7 +68,7 @@ public class ClusteredQueueExample extends ActiveMQExample
|
|||
|
||||
// Step 4. Get an initial context for looking up JNDI from server 1
|
||||
properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[1]);
|
||||
ic1 = new InitialContext(properties);
|
||||
|
||||
|
|
|
@ -105,7 +105,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ClusteredStandaloneExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ClusteredStandaloneExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:61617</param>
|
||||
|
|
|
@ -52,18 +52,18 @@ public class ClusteredStandaloneExample extends ActiveMQExample
|
|||
try
|
||||
{
|
||||
Hashtable<String, Object> properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[0]);
|
||||
properties.put("topic.topic/exampleTopic", "exampleTopic");
|
||||
initialContext0 = new InitialContext(properties);
|
||||
|
||||
properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[1]);
|
||||
initialContext1 = new InitialContext(properties);
|
||||
|
||||
properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[2]);
|
||||
initialContext2 = new InitialContext(properties);
|
||||
|
||||
|
|
|
@ -97,7 +97,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.StaticClusteredQueueExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.StaticClusteredQueueExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:61617</param>
|
||||
|
|
|
@ -59,7 +59,7 @@ public class StaticClusteredQueueExample extends ActiveMQExample
|
|||
{
|
||||
// Step 1. Get an initial context for looking up JNDI from server 3
|
||||
Hashtable<String, Object> properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[3]);
|
||||
properties.put("queue.queue/exampleQueue", "exampleQueue");
|
||||
ic0 = new InitialContext(properties);
|
||||
|
|
|
@ -87,7 +87,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ClusterStaticOnewayExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ClusterStaticOnewayExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:61617</param>
|
||||
|
|
|
@ -57,7 +57,7 @@ public class ClusterStaticOnewayExample extends ActiveMQExample
|
|||
{
|
||||
// Step 1. Get an initial context for looking up JNDI from server 0
|
||||
Hashtable<String, Object> properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[0]);
|
||||
properties.put("queue.queue/exampleQueue", "exampleQueue");
|
||||
ic0 = new InitialContext(properties);
|
||||
|
|
|
@ -97,7 +97,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ClusteredTopicExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ClusteredTopicExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:61617</param>
|
||||
|
|
|
@ -55,7 +55,7 @@ public class ClusteredTopicExample extends ActiveMQExample
|
|||
{
|
||||
// Step 1. Get an initial context for looking up JNDI from server 0
|
||||
Hashtable<String, Object> properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[0]);
|
||||
properties.put("topic.topic/exampleTopic", "exampleTopic");
|
||||
ic0 = new InitialContext(properties);
|
||||
|
@ -68,7 +68,7 @@ public class ClusteredTopicExample extends ActiveMQExample
|
|||
|
||||
// Step 4. Get an initial context for looking up JNDI from server 1
|
||||
properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[1]);
|
||||
ic1 = new InitialContext(properties);
|
||||
|
||||
|
|
|
@ -89,7 +89,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ColocatedFailoverScaleDownExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ColocatedFailoverScaleDownExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:61617</param>
|
||||
|
|
|
@ -55,12 +55,12 @@ public class ColocatedFailoverScaleDownExample extends ActiveMQExample
|
|||
{
|
||||
// Step 1. Get an initial context for looking up JNDI for both servers
|
||||
Hashtable<String, Object> properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[1]);
|
||||
initialContext1 = new InitialContext(properties);
|
||||
|
||||
properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[0] + "?ha=true&retryInterval=1000&retryIntervalMultiplier=1.0&reconnectAttempts=-1");
|
||||
properties.put("queue.queue/exampleQueue", "exampleQueue");
|
||||
initialContext = new InitialContext(properties);
|
||||
|
|
|
@ -89,7 +89,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ColocatedFailoverExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ColocatedFailoverExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:61617</param>
|
||||
|
|
|
@ -55,12 +55,12 @@ public class ColocatedFailoverExample extends ActiveMQExample
|
|||
{
|
||||
// Step 1. Get an initial context for looking up JNDI for both servers
|
||||
Hashtable<String, Object> properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[1]);
|
||||
initialContext1 = new InitialContext(properties);
|
||||
|
||||
properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[0] + "?ha=true&retryInterval=1000&retryIntervalMultiplier=1.0&reconnectAttempts=-1");
|
||||
properties.put("queue.queue/exampleQueue", "exampleQueue");
|
||||
initialContext = new InitialContext(properties);
|
||||
|
|
|
@ -72,7 +72,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ConsumerRateLimitExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ConsumerRateLimitExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
</args>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616?consumerMaxRate=10
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
|
|
|
@ -72,7 +72,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.DeadLetterExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.DeadLetterExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
</args>
|
||||
|
|
|
@ -15,7 +15,7 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
queue.queue/deadLetterQueue=deadLetterQueue
|
||||
|
|
|
@ -64,7 +64,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.DelayedRedeliveryExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.DelayedRedeliveryExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
</args>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
|
|
|
@ -82,7 +82,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.DivertExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.DivertExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:61617</param>
|
||||
|
|
|
@ -88,7 +88,7 @@ under the License.
|
|||
<address>jms.topic.priceUpdates</address>
|
||||
<forwarding-address>jms.queue.priceForwarding</forwarding-address>
|
||||
<filter string="office='New York'"/>
|
||||
<transformer-class-name>org.apache.activemq.jms.example.AddForwardingTimeTransformer</transformer-class-name>
|
||||
<transformer-class-name>org.apache.activemq.artemis.jms.example.AddForwardingTimeTransformer</transformer-class-name>
|
||||
<exclusive>true</exclusive>
|
||||
</divert>
|
||||
</code>
|
||||
|
|
|
@ -58,7 +58,7 @@ public class DivertExample extends ActiveMQExample
|
|||
{
|
||||
// Step 1. Create an initial context to perform the JNDI lookup on the London server
|
||||
Hashtable<String, Object> properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[0]);
|
||||
properties.put("queue.queue/orders", "orders");
|
||||
properties.put("topic.topic/priceUpdates", "priceUpdates");
|
||||
|
@ -77,7 +77,7 @@ public class DivertExample extends ActiveMQExample
|
|||
|
||||
// Step 6. Create an initial context to perform the JNDI lookup on the New York server
|
||||
properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[1]);
|
||||
properties.put("topic.topic/newYorkPriceUpdates", "newYorkPriceUpdates");
|
||||
initialContextNewYork = new InitialContext(properties);
|
||||
|
|
|
@ -87,7 +87,7 @@ under the License.
|
|||
<address>jms.topic.priceUpdates</address>
|
||||
<forwarding-address>jms.queue.priceForwarding</forwarding-address>
|
||||
<filter string="office='New York'"/>
|
||||
<transformer-class-name>org.apache.activemq.jms.example.AddForwardingTimeTransformer
|
||||
<transformer-class-name>org.apache.activemq.artemis.jms.example.AddForwardingTimeTransformer
|
||||
</transformer-class-name>
|
||||
<exclusive>true</exclusive>
|
||||
</divert>
|
||||
|
|
|
@ -72,7 +72,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.DurableSubscriptionExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.DurableSubscriptionExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
</args>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
topic.topic/exampleTopic=exampleTopic
|
||||
|
|
|
@ -68,7 +68,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.EmbeddedExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.EmbeddedExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:61616</param>
|
||||
|
|
|
@ -68,7 +68,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.EmbeddedExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.EmbeddedExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:61617</param>
|
||||
|
|
|
@ -72,7 +72,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ExpiryExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ExpiryExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
</args>
|
||||
|
|
|
@ -15,7 +15,7 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
queue.queue/expiryQueue=expiryQueue
|
||||
|
|
|
@ -89,7 +89,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.HAPolicyAutoBackupExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.HAPolicyAutoBackupExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:61617</param>
|
||||
|
|
|
@ -66,13 +66,13 @@ public class HAPolicyAutoBackupExample extends ActiveMQExample
|
|||
{
|
||||
// Step 1. Get an initial context for looking up JNDI from server 0 and 1
|
||||
Hashtable<String, Object> properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[0] + "?ha=true&retryInterval=1000&retryIntervalMultiplier=1.0&reconnectAttempts=-1");
|
||||
properties.put("queue.queue/exampleQueue", "exampleQueue");
|
||||
ic0 = new InitialContext(properties);
|
||||
|
||||
properties = new Hashtable<String, Object>();
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
properties.put("connectionFactory.ConnectionFactory", args[1] + "?ha=true&retryInterval=1000&retryIntervalMultiplier=1.0&reconnectAttempts=-1");
|
||||
ic1 = new InitialContext(properties);
|
||||
|
||||
|
|
|
@ -72,7 +72,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.HttpTransportExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.HttpTransportExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
</args>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:8080?http-enabled=true
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
|
|
|
@ -82,7 +82,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.InstantiateConnectionFactoryExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.InstantiateConnectionFactoryExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
</args>
|
||||
|
|
|
@ -77,7 +77,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.InterceptorExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.InterceptorExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
</args>
|
||||
|
|
|
@ -45,7 +45,7 @@ under the License.
|
|||
<configuration>
|
||||
...
|
||||
<remoting-incoming-interceptors>
|
||||
<class-name>org.apache.activemq.jms.example.SimpleInterceptor</class-name>
|
||||
<class-name>org.apache.activemq.artemis.jms.example.SimpleInterceptor</class-name>
|
||||
</remoting-incoming-interceptors>
|
||||
...
|
||||
</configuration>
|
||||
|
|
|
@ -39,7 +39,7 @@ under the License.
|
|||
|
||||
|
||||
<remoting-incoming-interceptors>
|
||||
<class-name>org.apache.activemq.jms.example.SimpleInterceptor</class-name>
|
||||
<class-name>org.apache.activemq.artemis.jms.example.SimpleInterceptor</class-name>
|
||||
</remoting-incoming-interceptors>
|
||||
|
||||
<!-- Acceptors -->
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
|
|
|
@ -72,7 +72,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.JMSAutoCloseableExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.JMSAutoCloseableExample</clientClass>
|
||||
</configuration>
|
||||
</execution>
|
||||
<execution>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
|
|
|
@ -82,7 +82,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.JMSBridgeExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.JMSBridgeExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
<param>tcp://localhost:5455</param>
|
||||
|
|
|
@ -58,7 +58,7 @@ under the License.
|
|||
Bridge itself:</p>
|
||||
<pre class="prettyprint">
|
||||
<!-- The JMS Bridge -->
|
||||
<bean name="JMSBridge" class="org.apache.activemq.jms.bridge.impl.JMSBridgeImpl">
|
||||
<bean name="JMSBridge" class="org.apache.activemq.artemis.jms.bridge.impl.JMSBridgeImpl">
|
||||
...
|
||||
</bean>
|
||||
</pre>
|
||||
|
|
|
@ -164,7 +164,7 @@ public class JMSBridgeExample
|
|||
{
|
||||
Hashtable<String, String> jndiProps = new Hashtable<String, String>();
|
||||
jndiProps.put("connectionFactory.ConnectionFactory", server);
|
||||
jndiProps.put("java.naming.factory.initial", "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
|
||||
jndiProps.put("java.naming.factory.initial", "org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory");
|
||||
jndiProps.put("queue.target/queue", "target");
|
||||
jndiProps.put("topic.source/topic", "topic");
|
||||
return jndiProps;
|
||||
|
|
|
@ -72,7 +72,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.JMSCompletionListenerExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.JMSCompletionListenerExample</clientClass>
|
||||
</configuration>
|
||||
</execution>
|
||||
<execution>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
|
|
|
@ -72,7 +72,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.JMSContextExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.JMSContextExample</clientClass>
|
||||
</configuration>
|
||||
</execution>
|
||||
<execution>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
|
|
|
@ -72,7 +72,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.JMSSharedConsumerExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.JMSSharedConsumerExample</clientClass>
|
||||
<args>
|
||||
<param>tcp://localhost:61616</param>
|
||||
</args>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
topic.topic/exampleTopic=exampleTopic
|
||||
|
|
|
@ -100,7 +100,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.JMXExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.JMXExample</clientClass>
|
||||
</configuration>
|
||||
</execution>
|
||||
<execution>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
|
|
|
@ -72,7 +72,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.LargeMessageExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.LargeMessageExample</clientClass>
|
||||
<systemProperties>
|
||||
<property>
|
||||
<name>exampleConfigDir</name>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
|
|
|
@ -72,7 +72,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.LastValueQueueExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.LastValueQueueExample</clientClass>
|
||||
</configuration>
|
||||
</execution>
|
||||
<execution>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
|
|
|
@ -72,7 +72,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ManagementNotificationExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ManagementNotificationExample</clientClass>
|
||||
</configuration>
|
||||
</execution>
|
||||
<execution>
|
||||
|
|
|
@ -15,7 +15,7 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
topic.topic/notificationsTopic=notificationsTopic
|
||||
|
|
|
@ -72,7 +72,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.ManagementExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.ManagementExample</clientClass>
|
||||
</configuration>
|
||||
</execution>
|
||||
<execution>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
|
|
|
@ -95,7 +95,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.MessageCounterExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.MessageCounterExample</clientClass>
|
||||
</configuration>
|
||||
</execution>
|
||||
<execution>
|
||||
|
|
|
@ -15,7 +15,7 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
queue.queue/expiryQueue=expiryQueue
|
||||
|
|
|
@ -72,7 +72,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.MessageGroupExample</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.MessageGroupExample</clientClass>
|
||||
</configuration>
|
||||
</execution>
|
||||
<execution>
|
||||
|
|
|
@ -15,6 +15,6 @@
|
|||
# specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
java.naming.factory.initial=ActiveMQInitialContextFactory
|
||||
java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
|
||||
connectionFactory.ConnectionFactory=tcp://localhost:61616
|
||||
queue.queue/exampleQueue=exampleQueue
|
||||
|
|
|
@ -72,7 +72,7 @@ under the License.
|
|||
<goal>runClient</goal>
|
||||
</goals>
|
||||
<configuration>
|
||||
<clientClass>org.apache.activemq.jms.example.MessageGroup2Example</clientClass>
|
||||
<clientClass>org.apache.activemq.artemis.jms.example.MessageGroup2Example</clientClass>
|
||||
</configuration>
|
||||
</execution>
|
||||
<execution>
|
||||
|
|
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue