[jboss-svn-commits] JBL Code SVN: r12090 - in labs/jbossesb/trunk/qa/junit: src/org/jboss/soa/esb/server/jca and 1 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Tue May 22 20:30:10 EDT 2007
Author: bill.burke at jboss.com
Date: 2007-05-22 20:30:09 -0400 (Tue, 22 May 2007)
New Revision: 12090
Removed:
labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/server/jca/CustomGateway.java
labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/server/jca/MdbEndpoint.java
Modified:
labs/jbossesb/trunk/qa/junit/resources/server/jca/META-INF/jboss-esb.xml
labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/server/jca/unit/JcaUnitTestCase.java
Log:
added <jca-gateway> element
Modified: labs/jbossesb/trunk/qa/junit/resources/server/jca/META-INF/jboss-esb.xml
===================================================================
--- labs/jbossesb/trunk/qa/junit/resources/server/jca/META-INF/jboss-esb.xml 2007-05-23 00:27:44 UTC (rev 12089)
+++ labs/jbossesb/trunk/qa/junit/resources/server/jca/META-INF/jboss-esb.xml 2007-05-23 00:30:09 UTC (rev 12090)
@@ -25,33 +25,14 @@
name="SimpleListener"
description="Hello World">
<listeners>
- <listener name="JMS-JCA-Gateway"
- busidref="syntax-sugar-bus"
- is-gateway="true">
- <property name="gatewayClass" value="org.jboss.soa.esb.listeners.jca.JcaInflowGateway"/>
- <property name="adapter" value="jms-ra.rar"/>
- <property name="endpointClass" value="org.jboss.soa.esb.server.jca.MdbEndpoint"/>
- <property name="activation">
+ <jca-gateway name="JMS-JCA-Gateway2"
+ adapter="jms-ra.rar"
+ endpointClass="org.jboss.soa.esb.listeners.jca.JmsEndpoint">
<activation-config>
- <activation-config-property>
- <activation-config-property-name>
- destinationType
- </activation-config-property-name>
- <activation-config-property-value>
- javax.jms.Queue
- </activation-config-property-value>
- </activation-config-property>
- <activation-config-property>
- <activation-config-property-name>
- destination
- </activation-config-property-name>
- <activation-config-property-value>
- queue/esb_gateway_channel
- </activation-config-property-value>
- </activation-config-property>
+ <property name="destinationType" value="javax.jms.Queue"/>
+ <property name="destination" value="queue/esb_gateway_channel"/>
</activation-config>
- </property>
- </listener>
+ </jca-gateway>
<jms-listener name="JMS-ESBListener"
busidref="esb-channel"
maxThreads="1"
Deleted: labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/server/jca/CustomGateway.java
===================================================================
--- labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/server/jca/CustomGateway.java 2007-05-23 00:27:44 UTC (rev 12089)
+++ labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/server/jca/CustomGateway.java 2007-05-23 00:30:09 UTC (rev 12090)
@@ -1,56 +0,0 @@
-/*
-* JBoss, Home of Professional Open Source
-* Copyright 2006, JBoss Inc., and individual contributors as indicated
-* 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.soa.esb.server.jca;
-
-import org.jboss.soa.esb.listeners.lifecycle.AbstractThreadedManagedLifecycle;
-import org.jboss.soa.esb.listeners.lifecycle.ManagedLifecycleException;
-import org.jboss.soa.esb.helpers.ConfigTree;
-import org.jboss.soa.esb.ConfigurationException;
-
-/**
- * comment
- *
- * @author <a href="bill at jboss.com">Bill Burke</a>
- * @version $Revision: 1.1 $
- */
-public class CustomGateway extends AbstractThreadedManagedLifecycle
-{
-
-
- public CustomGateway(final ConfigTree config)
- throws ConfigurationException
- {
- super(config);
- System.out.println("\n\n********** YO CONFIG****: \n" + config.toString());
- }
-
- protected void doRun()
- {
- System.out.println("DO RUN");
-
- }
-
- protected void doInitialise() throws ManagedLifecycleException
- {
- System.out.println("DO INITIALISE");
- }
-}
Deleted: labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/server/jca/MdbEndpoint.java
===================================================================
--- labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/server/jca/MdbEndpoint.java 2007-05-23 00:27:44 UTC (rev 12089)
+++ labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/server/jca/MdbEndpoint.java 2007-05-23 00:30:09 UTC (rev 12090)
@@ -1,60 +0,0 @@
-/*
-* JBoss, Home of Professional Open Source
-* Copyright 2006, JBoss Inc., and individual contributors as indicated
-* 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.soa.esb.server.jca;
-
-import org.jboss.soa.esb.listeners.ServiceInvoker;
-import org.jboss.soa.esb.listeners.gateway.PackageJmsMessageContents;
-import org.jboss.soa.esb.listeners.jca.InflowGateway;
-
-import javax.jms.Message;
-import javax.jms.MessageListener;
-
-/**
- * comment
- *
- * @author <a href="bill at jboss.com">Bill Burke</a>
- * @version $Revision: 1.1 $
- */
-public class MdbEndpoint implements InflowGateway, MessageListener
-{
- private ServiceInvoker service;
- private PackageJmsMessageContents transformer = new PackageJmsMessageContents();
-
- public void setServiceInvoker(ServiceInvoker invoker)
- {
- this.service = invoker;
- }
-
- public void onMessage(Message message)
- {
- try
- {
- System.out.println("HERE in ENDPOINT!!!!!");
- org.jboss.soa.esb.message.Message esbMessage = transformer.process(message);
- service.postMessage(esbMessage);
- }
- catch (Exception e)
- {
- throw new RuntimeException(e);
- }
- }
-}
Modified: labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/server/jca/unit/JcaUnitTestCase.java
===================================================================
--- labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/server/jca/unit/JcaUnitTestCase.java 2007-05-23 00:27:44 UTC (rev 12089)
+++ labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/server/jca/unit/JcaUnitTestCase.java 2007-05-23 00:30:09 UTC (rev 12090)
@@ -75,7 +75,7 @@
conn.close();
}
- public void testSimple() throws Exception
+ public void testSchemaBasedJcaGateway() throws Exception
{
sendAMessage("Hello World", "queue/esb_gateway_channel");
Thread.sleep(2000); // wait for message to post.
More information about the jboss-svn-commits
mailing list