[jboss-svn-commits] JBL Code SVN: r8796 - in labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg: src/quickstart and 1 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Wed Jan 10 09:58:38 EST 2007
Author: tfennelly
Date: 2007-01-10 09:58:34 -0500 (Wed, 10 Jan 2007)
New Revision: 8796
Added:
labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/base-build.xml
labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/jbossesb.xml
Removed:
labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/build.xml
labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/esb-config-gateway.xml
labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/esb-config.xml
Modified:
labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/src/quickstart/Launcher.java
labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/src/quickstart/test/SendJMSMessage.java
Log:
fixed up quickstart to launch from the StandaloneBootstrapper
Added: labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/base-build.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/base-build.xml 2007-01-10 14:51:28 UTC (rev 8795)
+++ labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/base-build.xml 2007-01-10 14:58:34 UTC (rev 8796)
@@ -0,0 +1,53 @@
+<project name="Base" default="run" basedir=".">
+
+ <property file="../quickstarts.properties" />
+
+ <property name="classes" value="build/classes" />
+
+ <path id="compile-classpath">
+ <fileset dir="lib" includes="*.jar" /> <!-- Quickstart Specific Jars. -->
+ <fileset dir="../../../lib/ext" includes="*.jar" /> <!-- Product Dependencies. -->
+ <fileset dir="${esb.product.lib.dir}" includes="*.jar" /> <!-- Product Jars. -->
+ </path>
+ <path id="exec-classpath">
+ <pathelement location="." />
+ <fileset dir="build" includes="${ant.project.name}.jar" />
+ <path refid="compile-classpath" />
+ <pathelement location="../../../" />
+ <fileset dir="${jbosshome.dir}/server/default/lib" includes="jboss-j2ee.jar" /> <!-- Required for JMS Client Code. -->
+ </path>
+
+ <target name="compile" depends="clean">
+ <mkdir dir="${classes}" />
+ <javac srcdir="src" destdir="${classes}">
+ <classpath refid="compile-classpath" />
+ </javac>
+ <jar basedir="${classes}" destfile="build/${ant.project.name}.jar" />
+ </target>
+
+ <target name="run" depends="compile">
+ <echo>Launching Quickstart in standalone mode...</echo>
+ <java fork="yes" classname="org.jboss.soa.esb.listeners.StandAloneBootStrapper" failonerror="true">
+ <arg value="jbossesb.xml" />
+ <classpath refid="exec-classpath" />
+ </java>
+ </target>
+
+ <target name="deployToSAR">
+ <echo>Deploys the project to the JBoss Application Server ESB SAR</echo>
+ <copy file="build/${ant.project.name}.jar" overwrite="true" todir="${jbosshome.dir}/server/default/deploy/jbossesb.sar" />
+ <copy file="jbossesb.xml" overwrite="true" todir="${jbosshome.dir}/server/default/conf" />
+ <touch file="${jbosshome.dir}/server/default/deploy/jbossesb.sar/META-INF/jboss-service.xml" />
+ <echo>Check your AS console to see if everything deployed properly then run 'ant runtest'</echo>
+ </target>
+
+ <target name="echoCP">
+ <property name="cp" refid="exec-classpath" />
+ <echo message="Classpath is ${cp}" />
+ </target>
+
+ <target name="clean">
+ <delete dir="build" />
+ </target>
+
+</project>
\ No newline at end of file
Deleted: labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/build.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/build.xml 2007-01-10 14:51:28 UTC (rev 8795)
+++ labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/build.xml 2007-01-10 14:58:34 UTC (rev 8796)
@@ -1,65 +0,0 @@
-<project name="Quickstart_helloworld" default="run" basedir=".">
-
- <property file="../quickstarts.properties" />
-
- <property name="build.dir" value="${basedir}/build"/>
- <property name="src.dir" value="${basedir}/src"/>
-
- <property name="quickstart.dir" value="${basedir}/.."/>
- <property name="esb-config"
- value="${quickstart.dir}/helloworld/esb-config.xml"/>
- <property name="esb-config-gateway"
- value="${quickstart.dir}/helloworld/esb-config-gateway.xml"/>
-
- <path id="classpath">
- <fileset dir="${basedir}/lib" includes="*.jar"/>
- <pathelement location="./" />
- <pathelement location="../../../" /> <!-- The root dir - access to the install dir etc. -->
- <pathelement location="${build.dir}"/>
- <fileset dir="${esb.product.lib.dir}" includes="*jar"/>
- <fileset dir="${esb.product.lib.dir}/ext" includes="*jar"/>
- <fileset dir="${jbosshome.dir}/client" includes="*jar"/>
- <fileset dir="${jbosshome.dir}/server/default/lib">
- <include name="jboss-j2ee.jar"/> <!-- added this for the JMS client -->
- </fileset>
-
- </path>
-
- <property name="cp" refid="classpath"/>
-
- <target name="echoCP">
- <echo message="Classpath is ${cp}"/>
- </target>
-
- <target name="prepare">
- <mkdir dir="${build.dir}" />
- </target>
-
- <target name="clean">
- <delete dir="${build.dir}" />
- </target>
-
- <target name="compile" depends="prepare">
- <javac srcdir="${src.dir}" destdir="${build.dir}" debug="true">
- <classpath refid="classpath"/>
- </javac>
- </target>
-
- <target name="run" depends="compile">
- <echo>Basic JMS Gateway and Listener</echo>
- <java fork="yes" classname="quickstart.Launcher" failonerror="true">
- <arg value="0"/>
- <arg value="${esb-config}"/>
- <arg value="${esb-config-gateway}"/>
- <classpath refid="classpath"/>
- </java>
- </target>
-
- <target name="runtest">
- <echo>Runs Test JMS Sender</echo>
- <java fork="yes" classname="quickstart.test.SendJMSMessage" failonerror="true">
- <arg value="Hello World"/>
- <classpath refid="classpath"/>
- </java>
- </target>
-</project>
\ No newline at end of file
Deleted: labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/esb-config-gateway.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/esb-config-gateway.xml 2007-01-10 14:51:28 UTC (rev 8795)
+++ labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/esb-config-gateway.xml 2007-01-10 14:58:34 UTC (rev 8796)
@@ -1,16 +0,0 @@
-
-<esb-config-gateway parameterReloadSecs="180">
- <esb-jms-gateway
- target-service-category="FirstServices"
- target-service-name="SimpleJMSService"
- gatewayClass="org.jboss.soa.esb.listeners.gateway.JmsGatewayListener"
- connection-factory="ConnectionFactory"
- destination-type="queue"
- destination-name="queue/quickstart_helloworld_Request"
- jndi-context-factory="org.jnp.interfaces.NamingContextFactory"
- jndi-URL="localhost"
- >
- <!-- no action needed as the inbound message is automatically converted
- and sent to the queue for the target service -->
- </esb-jms-gateway>
-</esb-config-gateway>
\ No newline at end of file
Deleted: labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/esb-config.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/esb-config.xml 2007-01-10 14:51:28 UTC (rev 8795)
+++ labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/esb-config.xml 2007-01-10 14:58:34 UTC (rev 8796)
@@ -1,16 +0,0 @@
-<esb-config parameterReloadSecs="180">
- <esb-listener
- service-category="FirstServices"
- service-name="SimpleJMSService"
- service-description="Simply listens for ESB Messages"
- epr-description="Hello World"
- listenerClass="org.jboss.soa.esb.listeners.message.JmsQueueListener"
- connection-factory="ConnectionFactory"
- destination-type="queue"
- destination-name="queue/B"
- jndi-context-factory="org.jnp.interfaces.NamingContextFactory"
- jndi-URL="localhost"
- >
- <action class="quickstart.MyJMSListenerAction" process="displayMessage" />
- </esb-listener>
-</esb-config>
\ No newline at end of file
Added: labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/jbossesb.xml
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/jbossesb.xml 2007-01-10 14:51:28 UTC (rev 8795)
+++ labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/jbossesb.xml 2007-01-10 14:58:34 UTC (rev 8796)
@@ -0,0 +1,42 @@
+<?xml version = "1.0" encoding = "UTF-8"?>
+<jbossesb
+ xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.0.xsd">
+
+ <providers>
+ <jms-provider name="JBossMQ"
+ connection-factory="ConnectionFactory"
+ jndi-context-factory="org.jnp.interfaces.NamingContextFactory"
+ jndi-URL="localhost">
+
+ <jms-bus busid="quickstartGwChannel">
+ <jms-message-filter dest-type="QUEUE" dest-name="queue/A" />
+ </jms-bus>
+ <jms-bus busid="quickstartEsbChannel">
+ <jms-message-filter dest-type="QUEUE" dest-name="queue/B" />
+ </jms-bus>
+
+ </jms-provider>
+ </providers>
+
+ <services>
+ <service category="FirstServicesGW" name="SimpleJMSGateway"
+ description="Hello World(gateway)" is-gateway="true"
+ target-service-category="FirstServiceESB"
+ target-service-name="SimpleListener">
+ <listeners>
+ <jms-listener name="JMS-Gateway" busidref="quickstartGwChannel" maxThreads="1" />
+ </listeners>
+ </service>
+
+ <service category="FirstServiceESB" name="SimpleListener"
+ description="Hello World" is-gateway="false">
+ <listeners>
+ <jms-listener name="quickstart" busidref="quickstartEsbChannel" maxThreads="1" />
+ </listeners>
+ <actions>
+ <action name="MyJMSListenerAction" class="quickstart.MyJMSListenerAction" process="displayMessage" />
+ </actions>
+ </service>
+ </services>
+
+</jbossesb>
Modified: labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/src/quickstart/Launcher.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/src/quickstart/Launcher.java 2007-01-10 14:51:28 UTC (rev 8795)
+++ labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/src/quickstart/Launcher.java 2007-01-10 14:58:34 UTC (rev 8796)
@@ -2,92 +2,32 @@
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
-import org.apache.log4j.Logger;
import org.jboss.soa.esb.common.Configuration;
-import org.jboss.soa.esb.listeners.gateway.GatewayListenerController;
-import org.jboss.soa.esb.listeners.message.EsbListenerController;
-import org.jboss.soa.esb.listeners.message.EsbListenerControllerFactory;
+import org.jboss.soa.esb.listeners.StandAloneBootStrapper;
-
public class Launcher {
private static Log log = LogFactory.getLog(Launcher.class);
- private EsbListenerController _esbListController;
- private GatewayListenerController _gatewayController;
-
- private Logger _logger = Logger.getLogger(Launcher.class);
-
public static void main (String args[]) throws Exception {
-
- log.info("args passed into Launcher: " + args.length);
- for (int x=0; x<args.length; x++)
- log.info("arg[" + x + "]=" + args[x]);
-
-
- Launcher launcher = new Launcher();
-
+
+ // Start Hypersonic...
if (Configuration.getStoreDriver().equals("org.hsqldb.jdbcDriver")) {
HsqldbUtil.startHsqldb();
}
try {
- launcher.triggerListener(Long.valueOf(args[0]).longValue(), args[1], args[2]);
+ // Start the ESB...
+ new StandAloneBootStrapper("jbossesb.xml");
+
+ // Loop forever...
+ while(true) {
+ Thread.sleep(10000);
+ }
} finally {
+ // Stop Hypersonic...
if (Configuration.getStoreDriver().equals("org.hsqldb.jdbcDriver")) {
HsqldbUtil.stopHsqldb();
}
}
}
-
- private void triggerListener(long runTime, String messageAwareConfigFile,
- String gatewayConfigFile) throws Exception{
- try
- {
-
- if (null != messageAwareConfigFile) {
- _logger.info("starting message aware listener with config file - " +
- messageAwareConfigFile);
- _esbListController = EsbListenerControllerFactory.getInstance(messageAwareConfigFile);
- }
- if (null != gatewayConfigFile) {
- _logger.info("starting gateway listener with config file - " +
- gatewayConfigFile);
- _gatewayController = new GatewayListenerController(gatewayConfigFile);
- new Thread(_gatewayController).start();
- }
-
- System.out.println("**Listener Ready**");
-
-
- while(true) {
- Thread.sleep(1000);
- }
-
-
-// This code is used to automatically shutdown the listeners which
-// might be useful for automated testing purposes. It is not needed
-// in the quickstart samples.
-// _logger.info("going to sleep now for " + runTime + " milliseconds...");
-// Thread.sleep(runTime);
-// if (null != messageAwareConfigFile) {
-// _logger.info("shutting down message aware listener...");
-// _esbListController.requestEnd();
-// }
-//
-// if (null != gatewayConfigFile) {
-// _logger.info("shutting down gateway listener...");
-// _gatewayController.requestEnd();
-// }
-
-
- }
- catch (Exception e) {
- _logger.error(e);
- throw(e);
- }
-
-
- }
-
-
}
\ No newline at end of file
Modified: labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/src/quickstart/test/SendJMSMessage.java
===================================================================
--- labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/src/quickstart/test/SendJMSMessage.java 2007-01-10 14:51:28 UTC (rev 8795)
+++ labs/jbossesb/trunk/product/samples/quickstarts/helloworld_embedded_reg/src/quickstart/test/SendJMSMessage.java 2007-01-10 14:58:34 UTC (rev 8796)
@@ -26,7 +26,7 @@
Object tmp = iniCtx.lookup("ConnectionFactory");
QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;
conn = qcf.createQueueConnection();
- que = (Queue) iniCtx.lookup("queue/quickstart_helloworld_Request");
+ que = (Queue) iniCtx.lookup("queue/A");
session = conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
conn.start();
System.out.println("Connection Started");
More information about the jboss-svn-commits
mailing list