[jboss-cvs] JBoss Messaging SVN: r6932 - in trunk/examples: common/src/org/jboss and 55 other directories.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Wed May 20 10:29:46 EDT 2009
Author: clebert.suconic at jboss.com
Date: 2009-05-20 10:29:45 -0400 (Wed, 20 May 2009)
New Revision: 6932
Added:
trunk/examples/common/src/org/jboss/common/example/JBMExample.java
trunk/examples/common/src/org/jboss/common/example/SpawnedJBMServer.java
Removed:
trunk/examples/common/src/org/jboss/common/example/JMSExample.java
trunk/examples/common/src/org/jboss/common/example/SpawnedJMSServer.java
trunk/examples/common/src/org/jboss/jms/
trunk/examples/core/embedded/src/org/jboss/jms/example/
Modified:
trunk/examples/common/build.xml
trunk/examples/jms/application-layer-failover/src/org/jboss/jms/example/ApplicationLayerFailoverExample.java
trunk/examples/jms/automatic-failover/src/org/jboss/jms/example/AutomaticFailoverExample.java
trunk/examples/jms/bridge/src/org/jboss/jms/example/BridgeExample.java
trunk/examples/jms/browser/src/org/jboss/jms/example/QueueBrowserExample.java
trunk/examples/jms/client-kickoff/src/org/jboss/jms/example/ClientKickoffExample.java
trunk/examples/jms/client-side-load-balancing/src/org/jboss/jms/example/ClientSideLoadBalancingExample.java
trunk/examples/jms/clustered-durable-subscription/src/org/jboss/jms/example/ClusteredDurableSubscriptionExample.java
trunk/examples/jms/clustered-queue/src/org/jboss/jms/example/ClusteredQueueExample.java
trunk/examples/jms/clustered-topic/src/org/jboss/jms/example/ClusteredTopicExample.java
trunk/examples/jms/consumer-rate-limit/src/org/jboss/jms/example/ConsumerRateLimitExample.java
trunk/examples/jms/dead-letter/src/org/jboss/jms/example/DeadLetterExample.java
trunk/examples/jms/delayed-redelivery/src/org/jboss/jms/example/DelayedRedeliveryExample.java
trunk/examples/jms/divert/src/org/jboss/jms/example/DivertExample.java
trunk/examples/jms/durable-subscription/src/org/jboss/jms/example/DurableSubscriptionExample.java
trunk/examples/jms/expiry/src/org/jboss/jms/example/ExpiryExample.java
trunk/examples/jms/http-transport/src/org/jboss/jms/example/HttpTransportExample.java
trunk/examples/jms/instantiate-connection-factory/src/org/jboss/jms/example/InstantiateConnectionFactoryExample.java
trunk/examples/jms/interceptor/src/org/jboss/jms/example/InterceptorExample.java
trunk/examples/jms/jaas/src/org/jboss/jms/example/JAASExample.java
trunk/examples/jms/jmx/src/org/jboss/jms/example/JMXExample.java
trunk/examples/jms/large-message/src/org/jboss/jms/example/LargeMessageExample.java
trunk/examples/jms/last-value-queue/src/org/jboss/jms/example/LastValueQueueExample.java
trunk/examples/jms/management-notifications/src/org/jboss/jms/example/ManagementNotificationExample.java
trunk/examples/jms/management/src/org/jboss/jms/example/ManagementExample.java
trunk/examples/jms/message-counters/src/org/jboss/jms/example/MessageCounterExample.java
trunk/examples/jms/message-group/src/org/jboss/jms/example/MessageGroupExample.java
trunk/examples/jms/message-priority/src/org/jboss/jms/example/MessagePriorityExample.java
trunk/examples/jms/no-consumer-buffering/src/org/jboss/jms/example/NoConsumerBufferingExample.java
trunk/examples/jms/paging/src/org/jboss/jms/example/PagingExample.java
trunk/examples/jms/pre-acknowledge/src/org/jboss/jms/example/PreacknowledgeExample.java
trunk/examples/jms/producer-rate-limit/src/org/jboss/jms/example/ProducerRateLimitExample.java
trunk/examples/jms/queue-message-redistribution/src/org/jboss/jms/example/QueueMessageRedistributionExample.java
trunk/examples/jms/queue-requestor/src/org/jboss/jms/example/QueueRequestorExample.java
trunk/examples/jms/queue-selector/src/org/jboss/jms/example/QueueSelectorExample.java
trunk/examples/jms/queue/src/org/jboss/jms/example/QueueExample.java
trunk/examples/jms/reconnect-same-node/src/org/jboss/jms/example/ReconnectSameNodeExample.java
trunk/examples/jms/request-reply/src/org/jboss/jms/example/RequestReplyExample.java
trunk/examples/jms/scheduled-message/src/org/jboss/jms/example/ScheduledMessageExample.java
trunk/examples/jms/security/src/org/jboss/jms/example/SecurityExample.java
trunk/examples/jms/send-acknowledgements/src/org/jboss/jms/example/SendAcknowledgementsExample.java
trunk/examples/jms/ssl-enabled/src/org/jboss/jms/example/SSLExample.java
trunk/examples/jms/static-selector/src/org/jboss/jms/example/StaticSelectorExample.java
trunk/examples/jms/symmetric-cluster/src/org/jboss/jms/example/SymmetricClusterExample.java
trunk/examples/jms/temp-queue/src/org/jboss/jms/example/TemporaryQueueExample.java
trunk/examples/jms/topic-hierarchies/src/org/jboss/jms/example/TopicHierarchyExample.java
trunk/examples/jms/topic-selector-example1/src/org/jboss/jms/example/TopicSelectorExample1.java
trunk/examples/jms/topic-selector-example2/src/org/jboss/jms/example/TopicSelectorExample2.java
trunk/examples/jms/topic/src/org/jboss/jms/example/TopicExample.java
trunk/examples/jms/transactional/src/org/jboss/jms/example/TransactionalExample.java
trunk/examples/jms/xa-heuristic/src/org/jboss/jms/example/XAHeuristicExample.java
trunk/examples/jms/xa-receive/src/org/jboss/jms/example/XAReceiveExample.java
trunk/examples/jms/xa-send/src/org/jboss/jms/example/XASendExample.java
trunk/examples/jms/xa-with-jta/src/org/jboss/jms/example/XAwithJTAExample.java
Log:
just renames on examples/common (removing jms terms)
Modified: trunk/examples/common/build.xml
===================================================================
--- trunk/examples/common/build.xml 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/common/build.xml 2009-05-20 14:29:45 UTC (rev 6932)
@@ -62,7 +62,7 @@
<path id="extra.classpath">
</path>
- <path id="jms.compilation.classpath">
+ <path id="compilation.classpath">
<fileset dir="${jbm.jars.dir}">
<include name="**/*.jar"/>
</fileset>
@@ -73,8 +73,8 @@
<path refid="extra.classpath"/>
</path>
- <path id="jms.runtime.classpath">
- <path refid="jms.compilation.classpath"/>
+ <path id="runtime.classpath">
+ <path refid="compilation.classpath"/>
<pathelement location="${config.dir}"/>
<pathelement location="${example.config.dir}"/>
<pathelement location="${classes.dir}"/>
@@ -103,7 +103,7 @@
<pathelement path="${src.dir}"/>
<pathelement path="${src.example.dir}"/>
</src>
- <classpath refid="jms.compilation.classpath"/>
+ <classpath refid="compilation.classpath"/>
</javac>
</target>
@@ -127,7 +127,7 @@
<jvmarg value="-Djbm.example.logserveroutput=${jbm.example.logserveroutput}"/>
<!--<jvmarg line="-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000"/>-->
<arg line="${jbm.example.beans.file}"/>
- <classpath refid="jms.runtime.classpath"/>
+ <classpath refid="runtime.classpath"/>
</java>
<!-- if the example exited with a result value != 0, we fail the build -->
<fail message="Example ${example.classname} failed">
@@ -169,7 +169,7 @@
</delete>
</target>
- <target name="all" description="Run all the JMS examples">
+ <target name="all" description="Run all the examples">
<subant target="run" failonerror="true">
<fileset dir=".." includes="*/build.xml" excludes="common/build.xml"/>
</subant>
Copied: trunk/examples/common/src/org/jboss/common/example/JBMExample.java (from rev 6923, trunk/examples/common/src/org/jboss/common/example/JMSExample.java)
===================================================================
--- trunk/examples/common/src/org/jboss/common/example/JBMExample.java (rev 0)
+++ trunk/examples/common/src/org/jboss/common/example/JBMExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -0,0 +1,244 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.common.example;
+
+import javax.jms.Connection;
+import javax.jms.JMSException;
+import javax.naming.InitialContext;
+import java.io.File;
+import java.io.FileInputStream;
+import java.util.Properties;
+import java.util.logging.Logger;
+
+/**
+ * a baee class for examples. This takes care of starting and stopping the server as well as deploying any queue needed.
+ *
+ * @author <a href="mailto:andy.taylor at jboss.org">Andy Taylor</a>
+ */
+public abstract class JBMExample
+{
+ protected static Logger log = Logger.getLogger(JBMExample.class.getName());
+
+ private Process[] servers;
+
+ private Connection conn;
+
+ private boolean failure = false;
+
+ public abstract boolean runExample() throws Exception;
+
+ private boolean logServerOutput;
+
+ private String[] allVMArgs;
+
+ private String[] configs;
+
+ private static final String[] defaultArgs = new String[] {"-Xms512M",
+ "-Xmx512M",
+ "-XX:+UseParallelGC",
+ "-XX:+AggressiveOpts",
+ "-XX:+UseFastAccessorMethods"};
+
+ protected void run(String[] serverVMArgs, String[] configs)
+ {
+ String runServerProp = System.getProperty("jbm.example.runServer");
+ String logServerOutputProp = System.getProperty("jbm.example.logserveroutput");
+ boolean runServer = runServerProp == null ? true : Boolean.valueOf(runServerProp);
+ logServerOutput = logServerOutputProp == null?false:Boolean.valueOf(logServerOutputProp);
+ log.info("jbm.example.runServer is " + runServer);
+
+ allVMArgs = new String[serverVMArgs == null ? 1 : serverVMArgs.length + 1];
+ if (serverVMArgs != null)
+ {
+ System.arraycopy(serverVMArgs, 0, allVMArgs, 0, serverVMArgs.length);
+ }
+ String logProps = System.getProperty("java.util.logging.config.file");
+ allVMArgs[allVMArgs.length - 1] = "-Djava.util.logging.config.file=" + logProps;
+
+ this.configs = configs;
+
+ try
+ {
+ if (runServer)
+ {
+ startServers();
+ }
+
+ if (!runExample())
+ {
+ failure = true;
+ }
+ }
+ catch (Throwable e)
+ {
+ failure = true;
+ e.printStackTrace();
+ }
+ finally
+ {
+ if (conn != null)
+ {
+ try
+ {
+ conn.close();
+ }
+ catch (JMSException e)
+ {
+ // ignore
+ }
+ }
+ if (runServer)
+ {
+ try
+ {
+ stopServers();
+ }
+ catch (Throwable throwable)
+ {
+ throwable.printStackTrace();
+ }
+ }
+ }
+ reportResultAndExit();
+ }
+
+ protected void run(String[] args)
+ {
+ run(defaultArgs, args);
+ }
+
+ protected void killServer(int id) throws Exception
+ {
+ System.out.println("Killing server " + id);
+
+ // We kill the server by creating a new file in the server dir which is checked for by the server
+ // We can't use Process.destroy() since this does not do a hard kill - it causes shutdown hooks
+ // to be called which cleanly shutdown the server
+ File file = new File("server" + id + "/KILL_ME");
+
+ file.createNewFile();
+ }
+
+ protected void stopServer(int id) throws Exception
+ {
+ System.out.println("Stopping server " + id);
+
+ stopServer(servers[id]);
+ }
+
+ protected InitialContext getContext(int serverId) throws Exception
+ {
+ String jndiFilename = "server" + serverId + "/client-jndi.properties";
+ File jndiFile = new File(jndiFilename);
+ log.info("using " + jndiFile + " for jndi");
+ Properties props = new Properties();
+ FileInputStream inStream = null;
+ try
+ {
+ inStream = new FileInputStream(jndiFile);
+ props.load(inStream);
+ }
+ finally
+ {
+ if(inStream != null)
+ {
+ inStream.close();
+ }
+ }
+ return new InitialContext(props);
+ }
+
+ protected void startServer(int index) throws Exception
+ {
+ String config = configs[index];
+ log.info("starting server with config '" + config + "' " + "logServerOutput " + logServerOutput);
+ StringBuilder args = new StringBuilder();
+ for (int i = 0; i < allVMArgs.length; i++)
+ {
+ args.append(allVMArgs[i]);
+ if (i != allVMArgs.length - 1)
+ {
+ args.append(",");
+ }
+ }
+ log.info("and vm args: " + args.toString());
+ servers[index] = SpawnedVMSupport.spawnVM(
+ SpawnedJBMServer.class.getName(),
+ allVMArgs,
+ logServerOutput,
+ "STARTED::",
+ "FAILED::",
+ config,
+ "jbm-jboss-beans.xml");
+ }
+
+ private void startServers() throws Exception
+ {
+ servers = new Process[configs.length];
+ for (int i = 0; i < configs.length; i++)
+ {
+ startServer(i);
+ }
+ }
+
+ private void stopServers() throws Exception
+ {
+ for (Process server : servers)
+ {
+ stopServer(server);
+ }
+ }
+
+ private void stopServer(Process server) throws Exception
+ {
+ if (server.getInputStream() != null)
+ {
+ server.getInputStream().close();
+ }
+ if (server.getErrorStream() != null)
+ {
+ server.getErrorStream().close();
+ }
+ server.destroy();
+ }
+
+
+ private void reportResultAndExit()
+ {
+ if (failure)
+ {
+ System.err.println();
+ System.err.println("#####################");
+ System.err.println("### FAILURE! ###");
+ System.err.println("#####################");
+ System.exit(1);
+ }
+ else
+ {
+ System.out.println();
+ System.out.println("#####################");
+ System.out.println("### SUCCESS! ###");
+ System.out.println("#####################");
+ System.exit(0);
+ }
+ }
+}
Deleted: trunk/examples/common/src/org/jboss/common/example/JMSExample.java
===================================================================
--- trunk/examples/common/src/org/jboss/common/example/JMSExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/common/src/org/jboss/common/example/JMSExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -1,244 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source
- * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors
- * by the @authors tag. See the copyright.txt in the distribution for a
- * full listing of individual contributors.
- *
- * This is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser General Public License as
- * published by the Free Software Foundation; either version 2.1 of
- * the License, or (at your option) any later version.
- *
- * This software is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this software; if not, write to the Free
- * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
- * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
- */
-package org.jboss.common.example;
-
-import javax.jms.Connection;
-import javax.jms.JMSException;
-import javax.naming.InitialContext;
-import java.io.File;
-import java.io.FileInputStream;
-import java.util.Properties;
-import java.util.logging.Logger;
-
-/**
- * a baee class for examples. This takes care of starting and stopping the server as well as deploying any queue needed.
- *
- * @author <a href="mailto:andy.taylor at jboss.org">Andy Taylor</a>
- */
-public abstract class JMSExample
-{
- protected static Logger log = Logger.getLogger(JMSExample.class.getName());
-
- private Process[] servers;
-
- private Connection conn;
-
- private boolean failure = false;
-
- public abstract boolean runExample() throws Exception;
-
- private boolean logServerOutput;
-
- private String[] allVMArgs;
-
- private String[] configs;
-
- private static final String[] defaultArgs = new String[] {"-Xms512M",
- "-Xmx512M",
- "-XX:+UseParallelGC",
- "-XX:+AggressiveOpts",
- "-XX:+UseFastAccessorMethods"};
-
- protected void run(String[] serverVMArgs, String[] configs)
- {
- String runServerProp = System.getProperty("jbm.example.runServer");
- String logServerOutputProp = System.getProperty("jbm.example.logserveroutput");
- boolean runServer = runServerProp == null ? true : Boolean.valueOf(runServerProp);
- logServerOutput = logServerOutputProp == null?false:Boolean.valueOf(logServerOutputProp);
- log.info("jbm.example.runServer is " + runServer);
-
- allVMArgs = new String[serverVMArgs == null ? 1 : serverVMArgs.length + 1];
- if (serverVMArgs != null)
- {
- System.arraycopy(serverVMArgs, 0, allVMArgs, 0, serverVMArgs.length);
- }
- String logProps = System.getProperty("java.util.logging.config.file");
- allVMArgs[allVMArgs.length - 1] = "-Djava.util.logging.config.file=" + logProps;
-
- this.configs = configs;
-
- try
- {
- if (runServer)
- {
- startServers();
- }
-
- if (!runExample())
- {
- failure = true;
- }
- }
- catch (Throwable e)
- {
- failure = true;
- e.printStackTrace();
- }
- finally
- {
- if (conn != null)
- {
- try
- {
- conn.close();
- }
- catch (JMSException e)
- {
- // ignore
- }
- }
- if (runServer)
- {
- try
- {
- stopServers();
- }
- catch (Throwable throwable)
- {
- throwable.printStackTrace();
- }
- }
- }
- reportResultAndExit();
- }
-
- protected void run(String[] args)
- {
- run(defaultArgs, args);
- }
-
- protected void killServer(int id) throws Exception
- {
- System.out.println("Killing server " + id);
-
- // We kill the server by creating a new file in the server dir which is checked for by the server
- // We can't use Process.destroy() since this does not do a hard kill - it causes shutdown hooks
- // to be called which cleanly shutdown the server
- File file = new File("server" + id + "/KILL_ME");
-
- file.createNewFile();
- }
-
- protected void stopServer(int id) throws Exception
- {
- System.out.println("Stopping server " + id);
-
- stopServer(servers[id]);
- }
-
- protected InitialContext getContext(int serverId) throws Exception
- {
- String jndiFilename = "server" + serverId + "/client-jndi.properties";
- File jndiFile = new File(jndiFilename);
- log.info("using " + jndiFile + " for jndi");
- Properties props = new Properties();
- FileInputStream inStream = null;
- try
- {
- inStream = new FileInputStream(jndiFile);
- props.load(inStream);
- }
- finally
- {
- if(inStream != null)
- {
- inStream.close();
- }
- }
- return new InitialContext(props);
- }
-
- protected void startServer(int index) throws Exception
- {
- String config = configs[index];
- log.info("starting server with config '" + config + "' " + "logServerOutput " + logServerOutput);
- StringBuilder args = new StringBuilder();
- for (int i = 0; i < allVMArgs.length; i++)
- {
- args.append(allVMArgs[i]);
- if (i != allVMArgs.length - 1)
- {
- args.append(",");
- }
- }
- log.info("and vm args: " + args.toString());
- servers[index] = SpawnedVMSupport.spawnVM(
- SpawnedJMSServer.class.getName(),
- allVMArgs,
- logServerOutput,
- "STARTED::",
- "FAILED::",
- config,
- "jbm-jboss-beans.xml");
- }
-
- private void startServers() throws Exception
- {
- servers = new Process[configs.length];
- for (int i = 0; i < configs.length; i++)
- {
- startServer(i);
- }
- }
-
- private void stopServers() throws Exception
- {
- for (Process server : servers)
- {
- stopServer(server);
- }
- }
-
- private void stopServer(Process server) throws Exception
- {
- if (server.getInputStream() != null)
- {
- server.getInputStream().close();
- }
- if (server.getErrorStream() != null)
- {
- server.getErrorStream().close();
- }
- server.destroy();
- }
-
-
- private void reportResultAndExit()
- {
- if (failure)
- {
- System.err.println();
- System.err.println("#####################");
- System.err.println("### FAILURE! ###");
- System.err.println("#####################");
- System.exit(1);
- }
- else
- {
- System.out.println();
- System.out.println("#####################");
- System.out.println("### SUCCESS! ###");
- System.out.println("#####################");
- System.exit(0);
- }
- }
-}
Copied: trunk/examples/common/src/org/jboss/common/example/SpawnedJBMServer.java (from rev 6923, trunk/examples/common/src/org/jboss/common/example/SpawnedJMSServer.java)
===================================================================
--- trunk/examples/common/src/org/jboss/common/example/SpawnedJBMServer.java (rev 0)
+++ trunk/examples/common/src/org/jboss/common/example/SpawnedJBMServer.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -0,0 +1,52 @@
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+package org.jboss.common.example;
+
+import org.jboss.messaging.integration.bootstrap.JBMBootstrapServer;
+
+/**
+ * @author <a href="mailto:andy.taylor at jboss.org">Andy Taylor</a>
+ */
+public class SpawnedJBMServer
+{
+ public static void main(String[] args)
+ {
+ JBMBootstrapServer bootstrap;
+ try
+ {
+ Thread killChecker = new KillChecker(".");
+ killChecker.setDaemon(true);
+ killChecker.start();
+
+ System.setProperty("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
+ System.setProperty("java.naming.factory.url.pkgs", "org.jboss.naming:org.jnp.interfaces");
+ System.setProperty("org.jboss.logging.Logger.pluginClass", "org.jboss.messaging.integration.logging.JBMLoggerPlugin");
+ bootstrap = new JBMBootstrapServer(args);
+ bootstrap.run();
+ System.out.println("STARTED::");
+ }
+ catch (Throwable e)
+ {
+ System.out.println("FAILED::" + e.getMessage());
+ }
+ }
+}
Deleted: trunk/examples/common/src/org/jboss/common/example/SpawnedJMSServer.java
===================================================================
--- trunk/examples/common/src/org/jboss/common/example/SpawnedJMSServer.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/common/src/org/jboss/common/example/SpawnedJMSServer.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -1,52 +0,0 @@
-/*
- * JBoss, Home of Professional Open Source
- * Copyright 2005-2008, Red Hat Middleware LLC, and individual contributors
- * by the @authors tag. See the copyright.txt in the distribution for a
- * full listing of individual contributors.
- *
- * This is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser General Public License as
- * published by the Free Software Foundation; either version 2.1 of
- * the License, or (at your option) any later version.
- *
- * This software is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this software; if not, write to the Free
- * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
- * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
- */
-package org.jboss.common.example;
-
-import org.jboss.messaging.integration.bootstrap.JBMBootstrapServer;
-
-/**
- * @author <a href="mailto:andy.taylor at jboss.org">Andy Taylor</a>
- */
-public class SpawnedJMSServer
-{
- public static void main(String[] args)
- {
- JBMBootstrapServer bootstrap;
- try
- {
- Thread killChecker = new KillChecker(".");
- killChecker.setDaemon(true);
- killChecker.start();
-
- System.setProperty("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
- System.setProperty("java.naming.factory.url.pkgs", "org.jboss.naming:org.jnp.interfaces");
- System.setProperty("org.jboss.logging.Logger.pluginClass", "org.jboss.messaging.integration.logging.JBMLoggerPlugin");
- bootstrap = new JBMBootstrapServer(args);
- bootstrap.run();
- System.out.println("STARTED::");
- }
- catch (Throwable e)
- {
- System.out.println("FAILED::" + e.getMessage());
- }
- }
-}
Modified: trunk/examples/jms/application-layer-failover/src/org/jboss/jms/example/ApplicationLayerFailoverExample.java
===================================================================
--- trunk/examples/jms/application-layer-failover/src/org/jboss/jms/example/ApplicationLayerFailoverExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/application-layer-failover/src/org/jboss/jms/example/ApplicationLayerFailoverExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -35,7 +35,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple example that demonstrates application-layer failover of the JMS connection from one node to another
@@ -43,7 +43,7 @@
*
* @author <a href="tim.fox at jboss.com>Tim Fox</a>
*/
-public class ApplicationLayerFailoverExample extends JMSExample
+public class ApplicationLayerFailoverExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/automatic-failover/src/org/jboss/jms/example/AutomaticFailoverExample.java
===================================================================
--- trunk/examples/jms/automatic-failover/src/org/jboss/jms/example/AutomaticFailoverExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/automatic-failover/src/org/jboss/jms/example/AutomaticFailoverExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,7 +30,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple example that demonstrates automatic failover of the JMS connection from one node to another
@@ -38,7 +38,7 @@
*
* @author <a href="tim.fox at jboss.com>Tim Fox</a>
*/
-public class AutomaticFailoverExample extends JMSExample
+public class AutomaticFailoverExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/bridge/src/org/jboss/jms/example/BridgeExample.java
===================================================================
--- trunk/examples/jms/bridge/src/org/jboss/jms/example/BridgeExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/bridge/src/org/jboss/jms/example/BridgeExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -31,7 +31,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* This example demonstrates a core bridge set-up between two nodes, consuming messages from a queue
@@ -39,7 +39,7 @@
*
* @author <a href="tim.fox at jboss.com>Tim Fox</a>
*/
-public class BridgeExample extends JMSExample
+public class BridgeExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/browser/src/org/jboss/jms/example/QueueBrowserExample.java
===================================================================
--- trunk/examples/jms/browser/src/org/jboss/jms/example/QueueBrowserExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/browser/src/org/jboss/jms/example/QueueBrowserExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -32,7 +32,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import java.util.Enumeration;
@@ -43,7 +43,7 @@
*
*
*/
-public class QueueBrowserExample extends JMSExample
+public class QueueBrowserExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/client-kickoff/src/org/jboss/jms/example/ClientKickoffExample.java
===================================================================
--- trunk/examples/jms/client-kickoff/src/org/jboss/jms/example/ClientKickoffExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/client-kickoff/src/org/jboss/jms/example/ClientKickoffExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -36,7 +36,7 @@
import javax.management.remote.JMXServiceURL;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import org.jboss.messaging.core.management.MessagingServerControlMBean;
import org.jboss.messaging.core.management.ObjectNames;
@@ -45,7 +45,7 @@
*
* @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
*/
-public class ClientKickoffExample extends JMSExample
+public class ClientKickoffExample extends JBMExample
{
private String JMX_URL = "service:jmx:rmi:///jndi/rmi://localhost:3000/jmxrmi";
Modified: trunk/examples/jms/client-side-load-balancing/src/org/jboss/jms/example/ClientSideLoadBalancingExample.java
===================================================================
--- trunk/examples/jms/client-side-load-balancing/src/org/jboss/jms/example/ClientSideLoadBalancingExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/client-side-load-balancing/src/org/jboss/jms/example/ClientSideLoadBalancingExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,7 +30,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* This example demonstrates how subsequent connections created from a single connection factory can be load
@@ -44,7 +44,7 @@
*
* @author <a href="tim.fox at jboss.com>Tim Fox</a>
*/
-public class ClientSideLoadBalancingExample extends JMSExample
+public class ClientSideLoadBalancingExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/clustered-durable-subscription/src/org/jboss/jms/example/ClusteredDurableSubscriptionExample.java
===================================================================
--- trunk/examples/jms/clustered-durable-subscription/src/org/jboss/jms/example/ClusteredDurableSubscriptionExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/clustered-durable-subscription/src/org/jboss/jms/example/ClusteredDurableSubscriptionExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,7 +30,7 @@
import javax.jms.Topic;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple example that shows a JMS Durable Subscription across two nodes of a cluster.
@@ -40,7 +40,7 @@
*
* @author <a href="tim.fox at jboss.com>Tim Fox</a>
*/
-public class ClusteredDurableSubscriptionExample extends JMSExample
+public class ClusteredDurableSubscriptionExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/clustered-queue/src/org/jboss/jms/example/ClusteredQueueExample.java
===================================================================
--- trunk/examples/jms/clustered-queue/src/org/jboss/jms/example/ClusteredQueueExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/clustered-queue/src/org/jboss/jms/example/ClusteredQueueExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,7 +30,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple example that demonstrates server side load-balancing of messages between the queue instances on different
@@ -38,7 +38,7 @@
*
* @author <a href="tim.fox at jboss.com>Tim Fox</a>
*/
-public class ClusteredQueueExample extends JMSExample
+public class ClusteredQueueExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/clustered-topic/src/org/jboss/jms/example/ClusteredTopicExample.java
===================================================================
--- trunk/examples/jms/clustered-topic/src/org/jboss/jms/example/ClusteredTopicExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/clustered-topic/src/org/jboss/jms/example/ClusteredTopicExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,7 +30,7 @@
import javax.jms.Topic;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple example that shows a JMS Topic clustered across two nodes of a cluster.
@@ -38,7 +38,7 @@
*
* @author <a href="tim.fox at jboss.com>Tim Fox</a>
*/
-public class ClusteredTopicExample extends JMSExample
+public class ClusteredTopicExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/consumer-rate-limit/src/org/jboss/jms/example/ConsumerRateLimitExample.java
===================================================================
--- trunk/examples/jms/consumer-rate-limit/src/org/jboss/jms/example/ConsumerRateLimitExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/consumer-rate-limit/src/org/jboss/jms/example/ConsumerRateLimitExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,7 +30,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* This example demonstrates how a message consumer can be limited to consumer messages at a maximum rate
@@ -38,7 +38,7 @@
*
* @author <a href="tim.fox at jboss.com">Tim Fox</a>
*/
-public class ConsumerRateLimitExample extends JMSExample
+public class ConsumerRateLimitExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/dead-letter/src/org/jboss/jms/example/DeadLetterExample.java
===================================================================
--- trunk/examples/jms/dead-letter/src/org/jboss/jms/example/DeadLetterExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/dead-letter/src/org/jboss/jms/example/DeadLetterExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,7 +30,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* An example showing how messages are moved to dead letter destination when they are unsuccessfully delivered multiple times
@@ -38,7 +38,7 @@
* @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
*
*/
-public class DeadLetterExample extends JMSExample
+public class DeadLetterExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/delayed-redelivery/src/org/jboss/jms/example/DelayedRedeliveryExample.java
===================================================================
--- trunk/examples/jms/delayed-redelivery/src/org/jboss/jms/example/DelayedRedeliveryExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/delayed-redelivery/src/org/jboss/jms/example/DelayedRedeliveryExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,7 +30,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* This example demonstrates how JBoss Messaging can be configured with a redelivery delay in the event a message
@@ -41,7 +41,7 @@
* @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
*
*/
-public class DelayedRedeliveryExample extends JMSExample
+public class DelayedRedeliveryExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/divert/src/org/jboss/jms/example/DivertExample.java
===================================================================
--- trunk/examples/jms/divert/src/org/jboss/jms/example/DivertExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/divert/src/org/jboss/jms/example/DivertExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -32,7 +32,7 @@
import javax.jms.Topic;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* This examples demonstrates the use of JBoss Messaging "Diverts" to transparently divert or copy messages
@@ -42,7 +42,7 @@
*
* @author <a href="tim.fox at jboss.com">Tim Fox</a>
*/
-public class DivertExample extends JMSExample
+public class DivertExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/durable-subscription/src/org/jboss/jms/example/DurableSubscriptionExample.java
===================================================================
--- trunk/examples/jms/durable-subscription/src/org/jboss/jms/example/DurableSubscriptionExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/durable-subscription/src/org/jboss/jms/example/DurableSubscriptionExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,14 +30,14 @@
import javax.jms.TopicSubscriber;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS example that shows how to use a durable subscription.
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class DurableSubscriptionExample extends JMSExample
+public class DurableSubscriptionExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/expiry/src/org/jboss/jms/example/ExpiryExample.java
===================================================================
--- trunk/examples/jms/expiry/src/org/jboss/jms/example/ExpiryExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/expiry/src/org/jboss/jms/example/ExpiryExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,7 +30,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* An example showing how messages are moved to an expiry queue when they expire.
@@ -38,7 +38,7 @@
* @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
*
*/
-public class ExpiryExample extends JMSExample
+public class ExpiryExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/http-transport/src/org/jboss/jms/example/HttpTransportExample.java
===================================================================
--- trunk/examples/jms/http-transport/src/org/jboss/jms/example/HttpTransportExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/http-transport/src/org/jboss/jms/example/HttpTransportExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,14 +30,14 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS Queue example that uses HTTP protocol.
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class HttpTransportExample extends JMSExample
+public class HttpTransportExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/instantiate-connection-factory/src/org/jboss/jms/example/InstantiateConnectionFactoryExample.java
===================================================================
--- trunk/examples/jms/instantiate-connection-factory/src/org/jboss/jms/example/InstantiateConnectionFactoryExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/instantiate-connection-factory/src/org/jboss/jms/example/InstantiateConnectionFactoryExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -34,7 +34,7 @@
import javax.jms.Session;
import javax.jms.TextMessage;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import org.jboss.messaging.core.config.TransportConfiguration;
import org.jboss.messaging.integration.transports.netty.NettyConnectorFactory;
import org.jboss.messaging.jms.JBossQueue;
@@ -50,7 +50,7 @@
* @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
*
*/
-public class InstantiateConnectionFactoryExample extends JMSExample
+public class InstantiateConnectionFactoryExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/interceptor/src/org/jboss/jms/example/InterceptorExample.java
===================================================================
--- trunk/examples/jms/interceptor/src/org/jboss/jms/example/InterceptorExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/interceptor/src/org/jboss/jms/example/InterceptorExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,14 +30,14 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS example that shows how to implement and use interceptors with JBoss Messaging.
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class InterceptorExample extends JMSExample
+public class InterceptorExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/jaas/src/org/jboss/jms/example/JAASExample.java
===================================================================
--- trunk/examples/jms/jaas/src/org/jboss/jms/example/JAASExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/jaas/src/org/jboss/jms/example/JAASExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,7 +30,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS Queue example that creates a producer and consumer on a queue and sends then receives a message.
@@ -38,7 +38,7 @@
*
* @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
*/
-public class JAASExample extends JMSExample
+public class JAASExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/jmx/src/org/jboss/jms/example/JMXExample.java
===================================================================
--- trunk/examples/jms/jmx/src/org/jboss/jms/example/JMXExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/jmx/src/org/jboss/jms/example/JMXExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -39,7 +39,7 @@
import javax.management.remote.JMXServiceURL;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import org.jboss.messaging.core.management.ObjectNames;
import org.jboss.messaging.jms.server.management.JMSQueueControlMBean;
@@ -48,7 +48,7 @@
*
* @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
*/
-public class JMXExample extends JMSExample
+public class JMXExample extends JBMExample
{
private static final String JMX_URL = "service:jmx:rmi:///jndi/rmi://localhost:3000/jmxrmi";
Modified: trunk/examples/jms/large-message/src/org/jboss/jms/example/LargeMessageExample.java
===================================================================
--- trunk/examples/jms/large-message/src/org/jboss/jms/example/LargeMessageExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/large-message/src/org/jboss/jms/example/LargeMessageExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -38,7 +38,7 @@
import javax.jms.Session;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* This example demonstrates the ability of JBoss Messaging to send and consume a very large message, much
@@ -47,7 +47,7 @@
* @author <a href="tim.fox at jboss.com">Tim Fox</a>
* @author <a href="clebert.suconic at jboss.com">Clebert Suconic</a>
*/
-public class LargeMessageExample extends JMSExample
+public class LargeMessageExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/last-value-queue/src/org/jboss/jms/example/LastValueQueueExample.java
===================================================================
--- trunk/examples/jms/last-value-queue/src/org/jboss/jms/example/LastValueQueueExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/last-value-queue/src/org/jboss/jms/example/LastValueQueueExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -33,7 +33,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* This example shows how to configure and use a <em>Last-Value</em> queues.
@@ -42,7 +42,7 @@
* @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
*
*/
-public class LastValueQueueExample extends JMSExample
+public class LastValueQueueExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/management/src/org/jboss/jms/example/ManagementExample.java
===================================================================
--- trunk/examples/jms/management/src/org/jboss/jms/example/ManagementExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/management/src/org/jboss/jms/example/ManagementExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -34,7 +34,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import org.jboss.messaging.jms.JBossQueue;
import org.jboss.messaging.jms.server.management.impl.JMSManagementHelper;
@@ -43,7 +43,7 @@
*
* @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
*/
-public class ManagementExample extends JMSExample
+public class ManagementExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/management-notifications/src/org/jboss/jms/example/ManagementNotificationExample.java
===================================================================
--- trunk/examples/jms/management-notifications/src/org/jboss/jms/example/ManagementNotificationExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/management-notifications/src/org/jboss/jms/example/ManagementNotificationExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -36,7 +36,7 @@
import javax.jms.Topic;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import org.jboss.messaging.jms.JBossTopic;
/**
@@ -44,7 +44,7 @@
*
* @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
*/
-public class ManagementNotificationExample extends JMSExample
+public class ManagementNotificationExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/message-counters/src/org/jboss/jms/example/MessageCounterExample.java
===================================================================
--- trunk/examples/jms/message-counters/src/org/jboss/jms/example/MessageCounterExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/message-counters/src/org/jboss/jms/example/MessageCounterExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -39,7 +39,7 @@
import javax.management.remote.JMXServiceURL;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import org.jboss.messaging.core.management.MessageCounterInfo;
import org.jboss.messaging.core.management.ObjectNames;
import org.jboss.messaging.jms.server.management.JMSQueueControlMBean;
@@ -50,7 +50,7 @@
* @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
*
*/
-public class MessageCounterExample extends JMSExample
+public class MessageCounterExample extends JBMExample
{
private String JMX_URL = "service:jmx:rmi:///jndi/rmi://localhost:3001/jmxrmi";
Modified: trunk/examples/jms/message-group/src/org/jboss/jms/example/MessageGroupExample.java
===================================================================
--- trunk/examples/jms/message-group/src/org/jboss/jms/example/MessageGroupExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/message-group/src/org/jboss/jms/example/MessageGroupExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -36,7 +36,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import org.jboss.messaging.jms.client.JBossMessage;
/**
@@ -44,7 +44,7 @@
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class MessageGroupExample extends JMSExample
+public class MessageGroupExample extends JBMExample
{
private Map<String, String> messageReceiverMap = new ConcurrentHashMap<String, String>();
private boolean result = true;
Modified: trunk/examples/jms/message-priority/src/org/jboss/jms/example/MessagePriorityExample.java
===================================================================
--- trunk/examples/jms/message-priority/src/org/jboss/jms/example/MessagePriorityExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/message-priority/src/org/jboss/jms/example/MessagePriorityExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -36,14 +36,14 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS example that shows the delivery order of messages with priorities.
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class MessagePriorityExample extends JMSExample
+public class MessagePriorityExample extends JBMExample
{
private volatile boolean result = true;
private ArrayList<TextMessage> msgReceived = new ArrayList<TextMessage>();
Modified: trunk/examples/jms/no-consumer-buffering/src/org/jboss/jms/example/NoConsumerBufferingExample.java
===================================================================
--- trunk/examples/jms/no-consumer-buffering/src/org/jboss/jms/example/NoConsumerBufferingExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/no-consumer-buffering/src/org/jboss/jms/example/NoConsumerBufferingExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,7 +30,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* This example demonstrates how JBoss Messaging consumers can be configured to not buffer any messages from
@@ -38,7 +38,7 @@
*
* @author <a href="tim.fox at jboss.com">Tim Fox</a>
*/
-public class NoConsumerBufferingExample extends JMSExample
+public class NoConsumerBufferingExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/paging/src/org/jboss/jms/example/PagingExample.java
===================================================================
--- trunk/examples/jms/paging/src/org/jboss/jms/example/PagingExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/paging/src/org/jboss/jms/example/PagingExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -31,14 +31,14 @@
import javax.jms.Session;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS Queue example that creates a producer and consumer on a queue and sends then receives a message.
*
* @author <a href="csuconic at redhat.com">Clebert Suconic</a>
*/
-public class PagingExample extends JMSExample
+public class PagingExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/pre-acknowledge/src/org/jboss/jms/example/PreacknowledgeExample.java
===================================================================
--- trunk/examples/jms/pre-acknowledge/src/org/jboss/jms/example/PreacknowledgeExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/pre-acknowledge/src/org/jboss/jms/example/PreacknowledgeExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -35,7 +35,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import org.jboss.messaging.jms.JBossQueue;
import org.jboss.messaging.jms.client.JBossSession;
import org.jboss.messaging.jms.server.management.impl.JMSManagementHelper;
@@ -50,7 +50,7 @@
* @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
*
*/
-public class PreacknowledgeExample extends JMSExample
+public class PreacknowledgeExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/producer-rate-limit/src/org/jboss/jms/example/ProducerRateLimitExample.java
===================================================================
--- trunk/examples/jms/producer-rate-limit/src/org/jboss/jms/example/ProducerRateLimitExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/producer-rate-limit/src/org/jboss/jms/example/ProducerRateLimitExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,7 +30,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* This example demonstrates how a message producer can be limited to produce messages at a maximum rate
@@ -38,7 +38,7 @@
*
* @author <a href="tim.fox at jboss.com">Tim Fox</a>
*/
-public class ProducerRateLimitExample extends JMSExample
+public class ProducerRateLimitExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/queue/src/org/jboss/jms/example/QueueExample.java
===================================================================
--- trunk/examples/jms/queue/src/org/jboss/jms/example/QueueExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/queue/src/org/jboss/jms/example/QueueExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,14 +30,14 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS Queue example that creates a producer and consumer on a queue and sends then receives a message.
*
* @author <a href="ataylor at redhat.com">Andy Taylor</a>
*/
-public class QueueExample extends JMSExample
+public class QueueExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/queue-message-redistribution/src/org/jboss/jms/example/QueueMessageRedistributionExample.java
===================================================================
--- trunk/examples/jms/queue-message-redistribution/src/org/jboss/jms/example/QueueMessageRedistributionExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/queue-message-redistribution/src/org/jboss/jms/example/QueueMessageRedistributionExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,7 +30,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* This example demonstrates a queue with the same name deployed on two nodes of a cluster.
@@ -40,7 +40,7 @@
*
* @author <a href="tim.fox at jboss.com>Tim Fox</a>
*/
-public class QueueMessageRedistributionExample extends JMSExample
+public class QueueMessageRedistributionExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/queue-requestor/src/org/jboss/jms/example/QueueRequestorExample.java
===================================================================
--- trunk/examples/jms/queue-requestor/src/org/jboss/jms/example/QueueRequestorExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/queue-requestor/src/org/jboss/jms/example/QueueRequestorExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -31,14 +31,14 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS example that shows how to use queues requestors.
*
* @author <a href="mailto:jmesnil at redhat.com">Jeff Mesnil</a>
*/
-public class QueueRequestorExample extends JMSExample
+public class QueueRequestorExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/queue-selector/src/org/jboss/jms/example/QueueSelectorExample.java
===================================================================
--- trunk/examples/jms/queue-selector/src/org/jboss/jms/example/QueueSelectorExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/queue-selector/src/org/jboss/jms/example/QueueSelectorExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -33,14 +33,14 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS example that uses selectors with queue consumers.
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class QueueSelectorExample extends JMSExample
+public class QueueSelectorExample extends JBMExample
{
private volatile boolean result = true;
Modified: trunk/examples/jms/reconnect-same-node/src/org/jboss/jms/example/ReconnectSameNodeExample.java
===================================================================
--- trunk/examples/jms/reconnect-same-node/src/org/jboss/jms/example/ReconnectSameNodeExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/reconnect-same-node/src/org/jboss/jms/example/ReconnectSameNodeExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -31,7 +31,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import org.jboss.messaging.jms.JBossQueue;
import org.jboss.messaging.jms.server.management.impl.JMSManagementHelper;
@@ -42,7 +42,7 @@
*
* @author <a href="tim.fox at jboss.com>Tim Fox</a>
*/
-public class ReconnectSameNodeExample extends JMSExample
+public class ReconnectSameNodeExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/request-reply/src/org/jboss/jms/example/RequestReplyExample.java
===================================================================
--- trunk/examples/jms/request-reply/src/org/jboss/jms/example/RequestReplyExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/request-reply/src/org/jboss/jms/example/RequestReplyExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -35,7 +35,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import java.util.HashMap;
import java.util.Map;
@@ -45,7 +45,7 @@
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class RequestReplyExample extends JMSExample
+public class RequestReplyExample extends JBMExample
{
private Map<String, TextMessage> requestMap = new HashMap<String, TextMessage>();
Modified: trunk/examples/jms/scheduled-message/src/org/jboss/jms/example/ScheduledMessageExample.java
===================================================================
--- trunk/examples/jms/scheduled-message/src/org/jboss/jms/example/ScheduledMessageExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/scheduled-message/src/org/jboss/jms/example/ScheduledMessageExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -33,7 +33,7 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import org.jboss.messaging.core.message.impl.MessageImpl;
/**
@@ -41,7 +41,7 @@
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class ScheduledMessageExample extends JMSExample
+public class ScheduledMessageExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/security/src/org/jboss/jms/example/SecurityExample.java
===================================================================
--- trunk/examples/jms/security/src/org/jboss/jms/example/SecurityExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/security/src/org/jboss/jms/example/SecurityExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -32,14 +32,14 @@
import javax.jms.Topic;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS example that shows how to access messaging with security configured.
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class SecurityExample extends JMSExample
+public class SecurityExample extends JBMExample
{
private boolean result = true;
Modified: trunk/examples/jms/send-acknowledgements/src/org/jboss/jms/example/SendAcknowledgementsExample.java
===================================================================
--- trunk/examples/jms/send-acknowledgements/src/org/jboss/jms/example/SendAcknowledgementsExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/send-acknowledgements/src/org/jboss/jms/example/SendAcknowledgementsExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -29,7 +29,7 @@
import javax.jms.Session;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import org.jboss.messaging.core.client.ClientSession;
import org.jboss.messaging.core.client.SendAcknowledgementHandler;
import org.jboss.messaging.core.message.Message;
@@ -45,7 +45,7 @@
* @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
*
*/
-public class SendAcknowledgementsExample extends JMSExample
+public class SendAcknowledgementsExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/ssl-enabled/src/org/jboss/jms/example/SSLExample.java
===================================================================
--- trunk/examples/jms/ssl-enabled/src/org/jboss/jms/example/SSLExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/ssl-enabled/src/org/jboss/jms/example/SSLExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,14 +30,14 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS Queue example that uses SSL secure transport.
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class SSLExample extends JMSExample
+public class SSLExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/static-selector/src/org/jboss/jms/example/StaticSelectorExample.java
===================================================================
--- trunk/examples/jms/static-selector/src/org/jboss/jms/example/StaticSelectorExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/static-selector/src/org/jboss/jms/example/StaticSelectorExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -33,14 +33,14 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS example that shows how static message selectors work.
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class StaticSelectorExample extends JMSExample
+public class StaticSelectorExample extends JBMExample
{
private volatile boolean result = true;
Modified: trunk/examples/jms/symmetric-cluster/src/org/jboss/jms/example/SymmetricClusterExample.java
===================================================================
--- trunk/examples/jms/symmetric-cluster/src/org/jboss/jms/example/SymmetricClusterExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/symmetric-cluster/src/org/jboss/jms/example/SymmetricClusterExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,7 +30,7 @@
import javax.jms.TextMessage;
import javax.jms.Topic;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import org.jboss.messaging.jms.JBossQueue;
import org.jboss.messaging.jms.JBossTopic;
import org.jboss.messaging.jms.client.JBossConnectionFactory;
@@ -52,7 +52,7 @@
*
* @author <a href="tim.fox at jboss.com>Tim Fox</a>
*/
-public class SymmetricClusterExample extends JMSExample
+public class SymmetricClusterExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/temp-queue/src/org/jboss/jms/example/TemporaryQueueExample.java
===================================================================
--- trunk/examples/jms/temp-queue/src/org/jboss/jms/example/TemporaryQueueExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/temp-queue/src/org/jboss/jms/example/TemporaryQueueExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -31,14 +31,14 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS example that shows how to use temporary queues.
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class TemporaryQueueExample extends JMSExample
+public class TemporaryQueueExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/topic/src/org/jboss/jms/example/TopicExample.java
===================================================================
--- trunk/examples/jms/topic/src/org/jboss/jms/example/TopicExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/topic/src/org/jboss/jms/example/TopicExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,14 +30,14 @@
import javax.jms.Topic;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS Topic example that creates a producer and consumer on a queue and sends and receives a message.
*
* @author <a href="ataylor at redhat.com">Andy Taylor</a>
*/
-public class TopicExample extends JMSExample
+public class TopicExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/topic-hierarchies/src/org/jboss/jms/example/TopicHierarchyExample.java
===================================================================
--- trunk/examples/jms/topic-hierarchies/src/org/jboss/jms/example/TopicHierarchyExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/topic-hierarchies/src/org/jboss/jms/example/TopicHierarchyExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -31,7 +31,7 @@
import javax.jms.Topic;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import org.jboss.messaging.jms.JBossTopic;
/**
@@ -41,7 +41,7 @@
*
* @author <a href="tim.fox at jboss.com">Tim Fox</a>
*/
-public class TopicHierarchyExample extends JMSExample
+public class TopicHierarchyExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/topic-selector-example1/src/org/jboss/jms/example/TopicSelectorExample1.java
===================================================================
--- trunk/examples/jms/topic-selector-example1/src/org/jboss/jms/example/TopicSelectorExample1.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/topic-selector-example1/src/org/jboss/jms/example/TopicSelectorExample1.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,14 +30,14 @@
import javax.jms.Topic;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS Topic example that creates a producer and consumer on a queue and sends and receives a message.
*
* @author <a href="csuconic at redhat.com">Clebert Suconic</a>
*/
-public class TopicSelectorExample1 extends JMSExample
+public class TopicSelectorExample1 extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/topic-selector-example2/src/org/jboss/jms/example/TopicSelectorExample2.java
===================================================================
--- trunk/examples/jms/topic-selector-example2/src/org/jboss/jms/example/TopicSelectorExample2.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/topic-selector-example2/src/org/jboss/jms/example/TopicSelectorExample2.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -33,14 +33,14 @@
import javax.jms.Topic;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS example that consumes messages using selectors.
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class TopicSelectorExample2 extends JMSExample
+public class TopicSelectorExample2 extends JBMExample
{
private volatile boolean result = true;
Modified: trunk/examples/jms/transactional/src/org/jboss/jms/example/TransactionalExample.java
===================================================================
--- trunk/examples/jms/transactional/src/org/jboss/jms/example/TransactionalExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/transactional/src/org/jboss/jms/example/TransactionalExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -30,14 +30,14 @@
import javax.jms.TextMessage;
import javax.naming.InitialContext;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS example that sends and consume message transactionally.
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class TransactionalExample extends JMSExample
+public class TransactionalExample extends JBMExample
{
public static void main(String[] args)
{
Modified: trunk/examples/jms/xa-heuristic/src/org/jboss/jms/example/XAHeuristicExample.java
===================================================================
--- trunk/examples/jms/xa-heuristic/src/org/jboss/jms/example/XAHeuristicExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/xa-heuristic/src/org/jboss/jms/example/XAHeuristicExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -44,7 +44,7 @@
import javax.transaction.xa.XAResource;
import javax.transaction.xa.Xid;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import org.jboss.messaging.core.management.ObjectNames;
import org.jboss.messaging.core.transaction.impl.XidImpl;
import org.jboss.messaging.utils.UUIDGenerator;
@@ -54,7 +54,7 @@
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class XAHeuristicExample extends JMSExample
+public class XAHeuristicExample extends JBMExample
{
private volatile boolean result = true;
private ArrayList<String> receiveHolder = new ArrayList<String>();
Modified: trunk/examples/jms/xa-receive/src/org/jboss/jms/example/XAReceiveExample.java
===================================================================
--- trunk/examples/jms/xa-receive/src/org/jboss/jms/example/XAReceiveExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/xa-receive/src/org/jboss/jms/example/XAReceiveExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -33,7 +33,7 @@
import javax.transaction.xa.XAResource;
import javax.transaction.xa.Xid;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import org.jboss.messaging.core.transaction.impl.XidImpl;
import org.jboss.messaging.utils.UUIDGenerator;
@@ -42,7 +42,7 @@
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class XAReceiveExample extends JMSExample
+public class XAReceiveExample extends JBMExample
{
private volatile boolean result = true;
Modified: trunk/examples/jms/xa-send/src/org/jboss/jms/example/XASendExample.java
===================================================================
--- trunk/examples/jms/xa-send/src/org/jboss/jms/example/XASendExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/xa-send/src/org/jboss/jms/example/XASendExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -38,7 +38,7 @@
import javax.transaction.xa.XAResource;
import javax.transaction.xa.Xid;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
import org.jboss.messaging.core.transaction.impl.XidImpl;
import org.jboss.messaging.utils.UUIDGenerator;
@@ -47,7 +47,7 @@
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class XASendExample extends JMSExample
+public class XASendExample extends JBMExample
{
private volatile boolean result = true;
private ArrayList<String> receiveHolder = new ArrayList<String>();
Modified: trunk/examples/jms/xa-with-jta/src/org/jboss/jms/example/XAwithJTAExample.java
===================================================================
--- trunk/examples/jms/xa-with-jta/src/org/jboss/jms/example/XAwithJTAExample.java 2009-05-20 14:29:10 UTC (rev 6931)
+++ trunk/examples/jms/xa-with-jta/src/org/jboss/jms/example/XAwithJTAExample.java 2009-05-20 14:29:45 UTC (rev 6932)
@@ -37,14 +37,14 @@
import com.arjuna.ats.jta.TransactionManager;
-import org.jboss.common.example.JMSExample;
+import org.jboss.common.example.JBMExample;
/**
* A simple JMS example showing the JBoss Messaging XA support with JTA.
*
* @author <a href="hgao at redhat.com">Howard Gao</a>
*/
-public class XAwithJTAExample extends JMSExample
+public class XAwithJTAExample extends JBMExample
{
private volatile boolean result = true;
More information about the jboss-cvs-commits
mailing list