[jboss-svn-commits] JBL Code SVN: r26268 - in labs/jbossesb/branches/JBESB_4_4_GA_CP/product: install/conf and 5 other directories.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Sun Apr 26 07:47:10 EDT 2009
Author: kevin.conner at jboss.com
Date: 2009-04-26 07:47:09 -0400 (Sun, 26 Apr 2009)
New Revision: 26268
Added:
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/jca/ActivationMapper.java
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/jca/JBossActivationMapper.java
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/JmsListenerMapperJCAActivationTest.java
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_01.xml
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_02.xml
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_03.xml
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_04.xml
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_05.xml
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_06.xml
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_07.xml
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_08.xml
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_09.xml
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_10.xml
Modified:
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/docs/ProgrammersGuide.odt
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/install/conf/jbossesb-properties.xml
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/common/Environment.java
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/common/ModulePropertyManager.java
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/ListenerTagNames.java
labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/config/mappers/JmsListenerMapper.java
Log:
Add support for JCA activation mappers: JBESB-2547
Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/docs/ProgrammersGuide.odt
===================================================================
(Binary files differ)
Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/install/conf/jbossesb-properties.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/install/conf/jbossesb-properties.xml 2009-04-26 11:36:02 UTC (rev 26267)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/install/conf/jbossesb-properties.xml 2009-04-26 11:47:09 UTC (rev 26268)
@@ -103,6 +103,10 @@
<property name="abandoned-connection-timeout" value="10000"/>
<property name="abandoned-connection-time-interval" value="30000"/>
</properties>
+ <properties name="jca">
+ <property name="org.jboss.soa.esb.jca.activation.mapper.jms-ra.rar" value="org.jboss.soa.esb.listeners.jca.JBossActivationMapper"/>
+ </properties>
+
<properties name="dbstore">
<!-- connection manager type -->
Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/common/Environment.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/common/Environment.java 2009-04-26 11:36:02 UTC (rev 26267)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/common/Environment.java 2009-04-26 11:47:09 UTC (rev 26268)
@@ -265,4 +265,11 @@
* The JBoss JNDI URL package prefix.
*/
public static final String JBOSS_URL_PKG_PREFIX = ""; //"org.jboss.naming:org.jnp.interfaces"
+
+ /**
+ * Configuration options for JCA ActivationMappers
+ *
+ * org.jboss.soa.esb.jca.activation.mapper.<adapterName>
+ */
+ public static final String JCA_ACTIVATION_MAPPER = "org.jboss.soa.esb.jca.activation.mapper" ;
}
Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/common/ModulePropertyManager.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/common/ModulePropertyManager.java 2009-04-26 11:36:02 UTC (rev 26267)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/common/ModulePropertyManager.java 2009-04-26 11:47:09 UTC (rev 26268)
@@ -103,6 +103,8 @@
public static final String FILTER_MODULE = "filters";
public static final String SECURITY_MODULE = "security";
+
+ public static final String JCA_MODULE = "jca" ;
/**
* Get the property manager responsible for the module component in the
Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/ListenerTagNames.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/ListenerTagNames.java 2009-04-26 11:36:02 UTC (rev 26267)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/ListenerTagNames.java 2009-04-26 11:47:09 UTC (rev 26268)
@@ -159,4 +159,7 @@
public static final String SCHEDULE_SIMPLE_EXEC = "scheduleSimpleExec" ;
public static final String SCHEDULE_CRON_EXPRESSION = "scheduleCronExpression" ;
public static final String SCHEDULE_PROPERTIES = "ScheduleProperties" ;
+
+ /** JCA properties */
+ public static final String JCA_ACTIVATION_MAPPER = "jcaActivationMapper";
}
Modified: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/config/mappers/JmsListenerMapper.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/config/mappers/JmsListenerMapper.java 2009-04-26 11:36:02 UTC (rev 26267)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/config/mappers/JmsListenerMapper.java 2009-04-26 11:47:09 UTC (rev 26268)
@@ -21,16 +21,16 @@
package org.jboss.soa.esb.listeners.config.mappers;
-import java.util.ArrayList;
+import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
+import java.util.Map;
+import java.util.Set;
-import javax.jms.Queue;
-import javax.jms.Topic;
-
import org.apache.log4j.Logger;
import org.jboss.soa.esb.ConfigurationException;
import org.jboss.soa.esb.addressing.eprs.JMSEpr;
+import org.jboss.soa.esb.common.ModulePropertyManager;
import org.jboss.soa.esb.dom.YADOMUtil;
import org.jboss.soa.esb.listeners.ListenerTagNames;
import org.jboss.soa.esb.listeners.config.Generator.XMLBeansModel;
@@ -44,14 +44,17 @@
import org.jboss.soa.esb.listeners.config.xbeanmodel.PropertyDocument.Property;
import org.jboss.soa.esb.listeners.gateway.JmsGatewayListener;
import org.jboss.soa.esb.listeners.gateway.PackageJmsMessageContents;
+import org.jboss.soa.esb.listeners.jca.ActivationMapper;
import org.jboss.soa.esb.listeners.jca.JcaConstants;
import org.jboss.soa.esb.listeners.jca.JcaGatewayListener;
import org.jboss.soa.esb.listeners.jca.JcaJMSInflowMessageProcessorAdapter;
import org.jboss.soa.esb.listeners.jca.JcaJMSMessageAwareComposer;
import org.jboss.soa.esb.listeners.jca.JcaMessageAwareListener;
+import org.jboss.soa.esb.util.ClassUtil;
import org.w3c.dom.Element;
-import org.w3c.dom.NodeList;
+import com.arjuna.common.util.propertyservice.PropertyManager;
+
/**
* Performs the mapping of a <jms-listener> XSD based configuration to the "ConfigTree"
* style configuration, adding the "ConfigTree" listener config to the "root" node.
@@ -59,6 +62,8 @@
* @author <a href="mailto:tom.fennelly at jboss.com">tom.fennelly at jboss.com</a>
*/
public class JmsListenerMapper {
+ // The default JMS JCA adapter.
+ private static final String DEFAULT_JMS_ADAPTER = "jms-ra.rar" ;
@SuppressWarnings("unused")
private static Logger log = Logger.getLogger( JmsListenerMapper.class );
@@ -100,7 +105,7 @@
final Class<?> gatewayClass ;
if (provider instanceof JmsJcaProvider) {
final JmsJcaProvider jmsJcaProvider = (JmsJcaProvider)provider ;
- mapJmsJcaAttributes(listener, listenerNode, jmsJcaProvider, messageFilter) ;
+ mapJmsJcaAttributes(listener, listenerNode, bus, jmsJcaProvider, messageFilter) ;
gatewayClass = JcaGatewayListener.class ;
} else {
gatewayClass = JmsGatewayListener.class ;
@@ -159,20 +164,12 @@
toElement.setAttribute(JMSEpr.TRANSACTED_TAG, Boolean.toString( messageFilter.getTransacted()));
}
- /*
- * @throws ConfigurationException is one of the following activation-config
- * properties are overridden:
- * - destination
- * - destinationType
- * - messageSelector
- * - maxSession
- */
private static void mapJmsJcaAttributes(final JmsListener listener,
- final Element listenerNode, final JmsJcaProvider jmsJcaProvider,
+ final Element listenerNode, final JmsBus bus, final JmsJcaProvider jmsJcaProvider,
final JmsMessageFilter messageFilter)
throws ConfigurationException {
setAttribute(listenerNode, JcaConstants.ATTRIBUTE_ADAPTER,
- jmsJcaProvider.getAdapter(), "jms-ra.rar") ;
+ jmsJcaProvider.getAdapter(), DEFAULT_JMS_ADAPTER) ;
setAttribute(listenerNode, JcaConstants.ATTRIBUTE_ENDPOINT_CLASS,
jmsJcaProvider.getEndpointClass(), JcaJMSInflowMessageProcessorAdapter.class.getName()) ;
setAttribute(listenerNode, JcaConstants.ATTRIBUTE_MESSAGING_TYPE,
@@ -207,36 +204,35 @@
JcaJMSMessageAwareComposer.class.getName()) ;
}
- final Element activationConfigElement = YADOMUtil.addElement(listenerNode, JcaConstants.ELEMENT_ACTIVATION_CONFIG) ;
- addPropertyElement(activationConfigElement, "destination", messageFilter.getDestName()) ;
- if (jmsJcaProvider.isSetProviderAdapterJNDI())
- {
- addPropertyElement(activationConfigElement, "providerAdapterJNDI", jmsJcaProvider.getProviderAdapterJNDI()) ;
- }
+ final ActivationMapper activationMapper = getActivationMapper(listener, bus, jmsJcaProvider) ;
+ final Map<String, String> activationConfigValues = new HashMap<String, String>() ;
+ activationMapper.setDestination(activationConfigValues, messageFilter.getDestName()) ;
+ activationMapper.setProviderAdapterJNDI(activationConfigValues, jmsJcaProvider.getProviderAdapterJNDI()) ;
final int destType = messageFilter.getDestType().intValue() ;
if (destType == DestType.INT_QUEUE)
{
- addPropertyElement(activationConfigElement, "destinationType", Queue.class.getName()) ;
+ activationMapper.setDestinationType(activationConfigValues, true) ;
}
else if (destType == DestType.INT_TOPIC)
{
- addPropertyElement(activationConfigElement, "destinationType", Topic.class.getName()) ;
+ activationMapper.setDestinationType(activationConfigValues, false) ;
}
else
{
throw new ConfigurationException("Unknown destination type: " + messageFilter.getDestType()) ;
}
- if (messageFilter.getSelector() != null)
+ activationMapper.setMessageSelector(activationConfigValues, messageFilter.getSelector()) ;
+ final Integer maxThreads = (listener.isSetMaxThreads() ? new Integer(listener.getMaxThreads()) : null) ;
+ activationMapper.setMaxThreads(activationConfigValues, maxThreads) ;
+
+ final Element activationConfigElement = YADOMUtil.addElement(listenerNode, JcaConstants.ELEMENT_ACTIVATION_CONFIG) ;
+ for(Map.Entry<String, String> entry: activationConfigValues.entrySet())
{
- addPropertyElement(activationConfigElement, "messageSelector", messageFilter.getSelector()) ;
+ addPropertyElement(activationConfigElement, entry.getKey(), entry.getValue()) ;
}
- if (listener.getMaxThreads() > 0)
- {
- addPropertyElement(activationConfigElement, "maxSession", Integer.toString(listener.getMaxThreads())) ;
- }
- final List<String> defaultPropertyNames = getDefaultActivationConfigNames( activationConfigElement );
+ final Set<String> defaultPropertyNames = activationConfigValues.keySet() ;
log.debug("Default activation-config properties :" + defaultPropertyNames );
/*
@@ -256,16 +252,6 @@
}
}
}
-
- private static List<String> getDefaultActivationConfigNames(final Element activationConfigElement )
- {
- NodeList defaultActivationProperties = activationConfigElement.getElementsByTagName( "property" );
- final List<String> defaultPropertyNames = new ArrayList<String>(5);
- for (int i = defaultActivationProperties.getLength() ; i-->0 ; )
- defaultPropertyNames.add(defaultActivationProperties.item( i ).getAttributes().getNamedItem( "name" ).getNodeValue() );
-
- return defaultPropertyNames;
- }
private static void setAttribute(final Element listenerNode,
final String name, final String value)
@@ -297,4 +283,85 @@
propertyElement.setAttribute("name", name) ;
propertyElement.setAttribute("value", value) ;
}
+
+ private static ActivationMapper getActivationMapper(final JmsListener listener,
+ final JmsBus bus, final JmsJcaProvider jmsJcaProvider)
+ throws ConfigurationException
+ {
+ final String activationMapper = getActivationMapperClass(listener, bus, jmsJcaProvider); ;
+ if (activationMapper == null)
+ {
+ throw new ConfigurationException("Could not locate ActivationMapper for adapter " + jmsJcaProvider.getAdapter()) ;
+ }
+ final Class activationMapperClass ;
+ try
+ {
+ activationMapperClass = ClassUtil.forName(activationMapper.trim(), JmsListenerMapper.class) ;
+ }
+ catch (final ClassNotFoundException cnfe)
+ {
+ throw new ConfigurationException("Could not locate activation mapper class " + activationMapper, cnfe) ;
+ }
+
+ if (!ActivationMapper.class.isAssignableFrom(activationMapperClass))
+ {
+ throw new ConfigurationException("Activation mapper class " + activationMapper + " does not implement ActivationMapper interface") ;
+ }
+ try
+ {
+ return (ActivationMapper)(activationMapperClass.newInstance()) ;
+ }
+ catch (final Throwable th)
+ {
+ throw new ConfigurationException("Failed to instantiate activation mapper class " + activationMapper, th) ;
+ }
+ }
+
+ private static String getActivationMapperClass(final JmsListener listener,
+ final JmsBus bus, final JmsJcaProvider jmsJcaProvider)
+ throws ConfigurationException
+ {
+ final String listenerActivationMapper = findProperty(listener.getPropertyList(), ListenerTagNames.JCA_ACTIVATION_MAPPER) ;
+ if (listenerActivationMapper != null)
+ {
+ return listenerActivationMapper ;
+ }
+
+ final String busActivationMapper = findProperty(bus.getPropertyList(), ListenerTagNames.JCA_ACTIVATION_MAPPER) ;
+ if (busActivationMapper != null)
+ {
+ return busActivationMapper ;
+ }
+
+ final String providerActivationMapper = findProperty(jmsJcaProvider.getPropertyList(), ListenerTagNames.JCA_ACTIVATION_MAPPER) ;
+ if (providerActivationMapper != null)
+ {
+ return providerActivationMapper ;
+ }
+
+ final String adapter = (jmsJcaProvider.getAdapter() == null ? DEFAULT_JMS_ADAPTER : jmsJcaProvider.getAdapter()) ;
+
+ final PropertyManager propertyManager = ModulePropertyManager.getPropertyManager(ModulePropertyManager.JCA_MODULE);
+ final String activationMapper = propertyManager.getProperty("org.jboss.soa.esb.jca.activation.mapper." + adapter) ;
+ if (activationMapper == null)
+ {
+ throw new ConfigurationException("Could not locate activation mapper for adapter " + adapter) ;
+ }
+ return activationMapper ;
+ }
+
+ private static String findProperty(final List<Property> properties, final String name)
+ {
+ if ((properties != null) && (name != null))
+ {
+ for(Property property: properties)
+ {
+ if (name.equals(property.getName()))
+ {
+ return property.getValue() ;
+ }
+ }
+ }
+ return null ;
+ }
}
Added: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/jca/ActivationMapper.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/jca/ActivationMapper.java (rev 0)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/jca/ActivationMapper.java 2009-04-26 11:47:09 UTC (rev 26268)
@@ -0,0 +1,80 @@
+/*
+* 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.listeners.jca;
+
+import java.util.Map;
+
+import org.jboss.soa.esb.ConfigurationException;
+
+
+/**
+ * Mapper interface for configuring standard ESB properties.
+ *
+ * @author <a href="kevin.conner at jboss.com">Kevin Conner</a>
+ */
+public interface ActivationMapper
+{
+ /**
+ * Initialise the destination name in the activation configuration.
+ * @param activationConfig The current activation configuration.
+ * @param name The destination name.
+ * @throws ConfigurationException For invalid configuration.
+ */
+ public void setDestination(final Map<String, String> activationConfig, final String name)
+ throws ConfigurationException ;
+
+ /**
+ * Initialise the destination name in the activation configuration.
+ * @param activationConfig The current activation configuration.
+ * @param providerAdapterJNDI The provider adapter JNDI value or null is not specified.
+ * @throws ConfigurationException For invalid configuration.
+ */
+ public void setProviderAdapterJNDI(final Map<String, String> activationConfig, final String providerAdapterJNDI)
+ throws ConfigurationException ;
+
+ /**
+ * Initialise the destination name in the activation configuration.
+ * @param activationConfig The current activation configuration.
+ * @param queue True if specifying a JMS Queue, false is specifying a JMS Topic.
+ * @throws ConfigurationException For invalid configuration.
+ */
+ public void setDestinationType(final Map<String, String> activationConfig, final boolean queue)
+ throws ConfigurationException ;
+
+ /**
+ * Initialise the destination name in the activation configuration.
+ * @param activationConfig The current activation configuration.
+ * @param messageSelector The message selector or null if not specified.
+ * @throws ConfigurationException For invalid configuration.
+ */
+ public void setMessageSelector(final Map<String, String> activationConfig, final String messageSelector)
+ throws ConfigurationException ;
+
+ /**
+ * Initialise the destination name in the activation configuration.
+ * @param activationConfig The current activation configuration.
+ * @param maxThreads The maximum thread value or null if not specified.
+ * @throws ConfigurationException For invalid configuration.
+ */
+ public void setMaxThreads(final Map<String, String> activationConfig, final Integer maxThreads)
+ throws ConfigurationException ;
+}
Property changes on: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/jca/ActivationMapper.java
___________________________________________________________________
Name: svn:keywords
+ Rev Date
Name: svn:eol-style
+ native
Added: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/jca/JBossActivationMapper.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/jca/JBossActivationMapper.java (rev 0)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/jca/JBossActivationMapper.java 2009-04-26 11:47:09 UTC (rev 26268)
@@ -0,0 +1,107 @@
+/*
+* 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.listeners.jca;
+
+import java.util.Map;
+
+import javax.jms.Queue;
+import javax.jms.Topic;
+
+import org.jboss.soa.esb.ConfigurationException;
+
+
+/**
+ * Default activation mapper implementation for JBoss.
+ *
+ * @author <a href="kevin.conner at jboss.com">Kevin Conner</a>
+ */
+public class JBossActivationMapper implements ActivationMapper
+{
+ /**
+ * Initialise the destination name in the activation configuration.
+ * @param activationConfig The current activation configuration.
+ * @param name The destination name.
+ * @throws ConfigurationException For invalid configuration.
+ */
+ public void setDestination(final Map<String, String> activationConfig, final String name)
+ throws ConfigurationException
+ {
+ activationConfig.put("destination", name) ;
+ }
+
+ /**
+ * Initialise the destination name in the activation configuration.
+ * @param activationConfig The current activation configuration.
+ * @param providerAdapterJNDI The provider adapter JNDI value or null is not specified.
+ * @throws ConfigurationException For invalid configuration.
+ */
+ public void setProviderAdapterJNDI(final Map<String, String> activationConfig, final String providerAdapterJNDI)
+ throws ConfigurationException
+ {
+ if (providerAdapterJNDI != null)
+ {
+ activationConfig.put("providerAdapterJNDI", providerAdapterJNDI) ;
+ }
+ }
+
+ /**
+ * Initialise the destination name in the activation configuration.
+ * @param activationConfig The current activation configuration.
+ * @param queue True if specifying a JMS Queue, false is specifying a JMS Topic.
+ * @throws ConfigurationException For invalid configuration.
+ */
+ public void setDestinationType(final Map<String, String> activationConfig, final boolean queue)
+ throws ConfigurationException
+ {
+ activationConfig.put("destinationType", queue ? Queue.class.getName() :Topic.class.getName()) ;
+ }
+
+ /**
+ * Initialise the destination name in the activation configuration.
+ * @param activationConfig The current activation configuration.
+ * @param messageSelector The message selector or null if not specified.
+ * @throws ConfigurationException For invalid configuration.
+ */
+ public void setMessageSelector(final Map<String, String> activationConfig, final String messageSelector)
+ throws ConfigurationException
+ {
+ if (messageSelector != null)
+ {
+ activationConfig.put("messageSelector", messageSelector) ;
+ }
+ }
+
+ /**
+ * Initialise the destination name in the activation configuration.
+ * @param activationConfig The current activation configuration.
+ * @param maxThreads The maximum thread value or null if not specified.
+ * @throws ConfigurationException For invalid configuration.
+ */
+ public void setMaxThreads(final Map<String, String> activationConfig, final Integer maxThreads)
+ throws ConfigurationException
+ {
+ if (maxThreads != null)
+ {
+ activationConfig.put("maxSession", maxThreads.toString()) ;
+ }
+ }
+}
Property changes on: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/src/org/jboss/soa/esb/listeners/jca/JBossActivationMapper.java
___________________________________________________________________
Name: svn:keywords
+ Rev Date
Name: svn:eol-style
+ native
Added: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/JmsListenerMapperJCAActivationTest.java
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/JmsListenerMapperJCAActivationTest.java (rev 0)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/JmsListenerMapperJCAActivationTest.java 2009-04-26 11:47:09 UTC (rev 26268)
@@ -0,0 +1,359 @@
+/*
+ * 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.listeners.config.mappers;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertTrue;
+
+import java.io.InputStream;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import javax.jms.Queue;
+import javax.jms.Topic;
+
+import junit.framework.JUnit4TestAdapter;
+
+import org.jboss.soa.esb.ConfigurationException;
+import org.jboss.soa.esb.common.Environment;
+import org.jboss.soa.esb.common.ModulePropertyManager;
+import org.jboss.soa.esb.dom.YADOMUtil;
+import org.jboss.soa.esb.listeners.config.Generator;
+import org.jboss.soa.esb.listeners.config.Generator.XMLBeansModel;
+import org.jboss.soa.esb.listeners.config.xbeanmodel.Listener;
+import org.jboss.soa.esb.listeners.config.xbeanmodel.JmsListenerDocument.JmsListener;
+import org.jboss.soa.esb.listeners.jca.ActivationMapper;
+import org.jboss.soa.esb.listeners.jca.JBossActivationMapper;
+import org.jboss.soa.esb.listeners.jca.JcaConstants;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+import org.w3c.dom.Node;
+import org.w3c.dom.NodeList;
+
+import com.arjuna.common.util.propertyservice.PropertyManager;
+
+/**
+ * Tests the JCA activation mapping of the JmsListenerMapper
+ *
+ * @author <a href='mailto:kevin.conner at jboss.com'>Kevin Conner</a>
+ */
+public class JmsListenerMapperJCAActivationTest
+{
+ private static final String TEST_DESTINATION = "TestDestination" ;
+ private static final String TEST_PROVIDER_ADAPTER_JNDI = "TestProviderAdapterJNDI" ;
+ private static final String TEST_DESTINATION_TYPE = "TestDestinationType" ;
+ private static final String TEST_MESSAGE_SELECTOR = "TestMessageSelector" ;
+ private static final String TEST_MAX_THREADS = "TestMaxThreads" ;
+
+ private static final String TEST_QUEUE = "TestQueue" ;
+ private static final String TEST_TOPIC = "TestTopic" ;
+ private static final String DEFAULT_TEST_PROVIDER_ADAPTER_JNDI = "DefaultTestProviderAdapterJNDI" ;
+ private static final String DEFAULT_TEST_MESSAGE_SELECTOR = "DefaultTestMessageSelector" ;
+ private static final String DEFAULT_TEST_MAX_THREADS = "DefaultTestMaxThreads" ;
+
+ @BeforeClass
+ public static void setUp () throws Exception
+ {
+ final PropertyManager propertyManager = ModulePropertyManager.getPropertyManager(ModulePropertyManager.JCA_MODULE) ;
+ propertyManager.setProperty(Environment.JCA_ACTIVATION_MAPPER + ".jms-ra.rar", JBossActivationMapper.class.getName()) ;
+ propertyManager.setProperty(Environment.JCA_ACTIVATION_MAPPER + ".test-ra.rar", TestActivationMapper.class.getName()) ;
+ }
+
+ @Test
+ public void testDefaultAllValues()
+ throws Exception
+ {
+ final Map<String, String> activationConfig = generateConfig("jbossesb_jca_config_01.xml") ;
+
+ final Map<String, String> expected = new HashMap<String, String>() ;
+ expected.put("destination", "DestName") ;
+ expected.put("providerAdapterJNDI", "ProviderAdapterJNDI") ;
+ expected.put("destinationType", Queue.class.getName()) ;
+ expected.put("messageSelector", "selector") ;
+ expected.put("maxSession", "100") ;
+
+ verifyConfiguration(expected, activationConfig) ;
+ }
+
+ @Test
+ public void testDefaultMandatoryValues()
+ throws Exception
+ {
+ final Map<String, String> activationConfig = generateConfig("jbossesb_jca_config_02.xml") ;
+
+ final Map<String, String> expected = new HashMap<String, String>() ;
+ expected.put("destination", "DestName") ;
+ expected.put("destinationType", Topic.class.getName()) ;
+
+ verifyConfiguration(expected, activationConfig) ;
+ }
+
+ @Test
+ public void testAdapterAllValues()
+ throws Exception
+ {
+ final Map<String, String> activationConfig = generateConfig("jbossesb_jca_config_03.xml") ;
+
+ final Map<String, String> expected = new HashMap<String, String>() ;
+ expected.put(TEST_DESTINATION, "DestName") ;
+ expected.put(TEST_PROVIDER_ADAPTER_JNDI, "ProviderAdapterJNDI") ;
+ expected.put(TEST_DESTINATION_TYPE, TEST_QUEUE) ;
+ expected.put(TEST_MESSAGE_SELECTOR, "selector") ;
+ expected.put(TEST_MAX_THREADS, "100") ;
+
+ verifyConfiguration(expected, activationConfig) ;
+ }
+
+ @Test
+ public void testAdapterMandatoryValues()
+ throws Exception
+ {
+ final Map<String, String> activationConfig = generateConfig("jbossesb_jca_config_04.xml") ;
+
+ final Map<String, String> expected = new HashMap<String, String>() ;
+ expected.put(TEST_DESTINATION, "DestName") ;
+ expected.put(TEST_PROVIDER_ADAPTER_JNDI, DEFAULT_TEST_PROVIDER_ADAPTER_JNDI) ;
+ expected.put(TEST_DESTINATION_TYPE, TEST_TOPIC) ;
+ expected.put(TEST_MESSAGE_SELECTOR, DEFAULT_TEST_MESSAGE_SELECTOR) ;
+ expected.put(TEST_MAX_THREADS, DEFAULT_TEST_MAX_THREADS) ;
+
+ verifyConfiguration(expected, activationConfig) ;
+ }
+
+ @Test
+ public void testListenerPropertyAllValues()
+ throws Exception
+ {
+ final Map<String, String> activationConfig = generateConfig("jbossesb_jca_config_05.xml") ;
+
+ final Map<String, String> expected = new HashMap<String, String>() ;
+ expected.put(TEST_DESTINATION, "DestName") ;
+ expected.put(TEST_PROVIDER_ADAPTER_JNDI, "ProviderAdapterJNDI") ;
+ expected.put(TEST_DESTINATION_TYPE, TEST_QUEUE) ;
+ expected.put(TEST_MESSAGE_SELECTOR, "selector") ;
+ expected.put(TEST_MAX_THREADS, "100") ;
+
+ verifyConfiguration(expected, activationConfig) ;
+ }
+
+ @Test
+ public void testListenerPropertyMandatoryValues()
+ throws Exception
+ {
+ final Map<String, String> activationConfig = generateConfig("jbossesb_jca_config_06.xml") ;
+
+ final Map<String, String> expected = new HashMap<String, String>() ;
+ expected.put(TEST_DESTINATION, "DestName") ;
+ expected.put(TEST_PROVIDER_ADAPTER_JNDI, DEFAULT_TEST_PROVIDER_ADAPTER_JNDI) ;
+ expected.put(TEST_DESTINATION_TYPE, TEST_TOPIC) ;
+ expected.put(TEST_MESSAGE_SELECTOR, DEFAULT_TEST_MESSAGE_SELECTOR) ;
+ expected.put(TEST_MAX_THREADS, DEFAULT_TEST_MAX_THREADS) ;
+
+ verifyConfiguration(expected, activationConfig) ;
+ }
+
+ @Test
+ public void testBusPropertyAllValues()
+ throws Exception
+ {
+ final Map<String, String> activationConfig = generateConfig("jbossesb_jca_config_07.xml") ;
+
+ final Map<String, String> expected = new HashMap<String, String>() ;
+ expected.put(TEST_DESTINATION, "DestName") ;
+ expected.put(TEST_PROVIDER_ADAPTER_JNDI, "ProviderAdapterJNDI") ;
+ expected.put(TEST_DESTINATION_TYPE, TEST_QUEUE) ;
+ expected.put(TEST_MESSAGE_SELECTOR, "selector") ;
+ expected.put(TEST_MAX_THREADS, "100") ;
+
+ verifyConfiguration(expected, activationConfig) ;
+ }
+
+ @Test
+ public void testBusPropertyMandatoryValues()
+ throws Exception
+ {
+ final Map<String, String> activationConfig = generateConfig("jbossesb_jca_config_08.xml") ;
+
+ final Map<String, String> expected = new HashMap<String, String>() ;
+ expected.put(TEST_DESTINATION, "DestName") ;
+ expected.put(TEST_PROVIDER_ADAPTER_JNDI, DEFAULT_TEST_PROVIDER_ADAPTER_JNDI) ;
+ expected.put(TEST_DESTINATION_TYPE, TEST_TOPIC) ;
+ expected.put(TEST_MESSAGE_SELECTOR, DEFAULT_TEST_MESSAGE_SELECTOR) ;
+ expected.put(TEST_MAX_THREADS, DEFAULT_TEST_MAX_THREADS) ;
+
+ verifyConfiguration(expected, activationConfig) ;
+ }
+
+ @Test
+ public void testProviderPropertyAllValues()
+ throws Exception
+ {
+ final Map<String, String> activationConfig = generateConfig("jbossesb_jca_config_09.xml") ;
+
+ final Map<String, String> expected = new HashMap<String, String>() ;
+ expected.put(TEST_DESTINATION, "DestName") ;
+ expected.put(TEST_PROVIDER_ADAPTER_JNDI, "ProviderAdapterJNDI") ;
+ expected.put(TEST_DESTINATION_TYPE, TEST_QUEUE) ;
+ expected.put(TEST_MESSAGE_SELECTOR, "selector") ;
+ expected.put(TEST_MAX_THREADS, "100") ;
+
+ verifyConfiguration(expected, activationConfig) ;
+ }
+
+ @Test
+ public void testProviderPropertyMandatoryValues()
+ throws Exception
+ {
+ final Map<String, String> activationConfig = generateConfig("jbossesb_jca_config_10.xml") ;
+
+ final Map<String, String> expected = new HashMap<String, String>() ;
+ expected.put(TEST_DESTINATION, "DestName") ;
+ expected.put(TEST_PROVIDER_ADAPTER_JNDI, DEFAULT_TEST_PROVIDER_ADAPTER_JNDI) ;
+ expected.put(TEST_DESTINATION_TYPE, TEST_TOPIC) ;
+ expected.put(TEST_MESSAGE_SELECTOR, DEFAULT_TEST_MESSAGE_SELECTOR) ;
+ expected.put(TEST_MAX_THREADS, DEFAULT_TEST_MAX_THREADS) ;
+
+ verifyConfiguration(expected, activationConfig) ;
+ }
+
+ private Map<String, String> generateConfig(final String config)
+ throws Exception
+ {
+ final InputStream is = getClass().getResourceAsStream(config) ;
+ assertNotNull("Configuration " + config, is) ;
+ final XMLBeansModel model = Generator.parseConfig(is) ;
+
+ final List<Listener> awareListeners = model.getESBAwareListeners() ;
+ assertEquals("Listener count", 1, awareListeners.size()) ;
+
+ final Listener listener = awareListeners.get(0) ;
+ assertTrue("JmsListener", listener instanceof JmsListener) ;
+
+ final Document doc = YADOMUtil.createDocument() ;
+ final Element root = doc.createElement("root") ;
+ final Element listenerElement = JmsListenerMapper.map(root, (JmsListener)listener, model) ;
+ assertNotNull("Listener Element", listenerElement) ;
+
+ final NodeList activationNodes = listenerElement.getElementsByTagName(JcaConstants.ELEMENT_ACTIVATION_CONFIG) ;
+ final int numActivationNodes = (activationNodes == null ? 0 : activationNodes.getLength()) ;
+ assertEquals("Activation node count", 1, numActivationNodes) ;
+
+ final Element activationConfig = (Element)activationNodes.item(0) ;
+ final NodeList propertyNodes = activationConfig.getElementsByTagName(JcaConstants.ELEMENT_PROPERTY) ;
+
+ final Map<String, String> properties = new HashMap<String, String>() ;
+ final int numProperties = (propertyNodes == null ? 0 : propertyNodes.getLength()) ;
+ for(int count = 0 ; count < numProperties ; count++)
+ {
+ final Node node = propertyNodes.item(count) ;
+ if (node instanceof Element)
+ {
+ final Element element = (Element)node ;
+ final String name = element.getAttribute("name") ;
+ final String value = element.getAttribute("value") ;
+ properties.put(name, value) ;
+ }
+ }
+ return properties ;
+ }
+
+ private static void verifyConfiguration(final Map<String, String> expected, final Map<String, String> activationConfig)
+ {
+ assertEquals("Number of activation properties", expected.size(), activationConfig.size()) ;
+
+ for(Map.Entry<String, String> entry: expected.entrySet())
+ {
+ final String name = entry.getKey() ;
+ assertEquals("Value of " + name, expected.get(name), activationConfig.get(name)) ;
+ }
+ }
+
+ public static class TestActivationMapper implements ActivationMapper
+ {
+ public void setDestination(final Map<String, String> activationConfig, final String name)
+ throws ConfigurationException
+ {
+ activationConfig.put(TEST_DESTINATION, name) ;
+ }
+
+ public void setProviderAdapterJNDI(final Map<String, String> activationConfig, final String providerAdapterJNDI)
+ throws ConfigurationException
+ {
+ if (providerAdapterJNDI != null)
+ {
+ activationConfig.put(TEST_PROVIDER_ADAPTER_JNDI, providerAdapterJNDI) ;
+ }
+ else
+ {
+ activationConfig.put(TEST_PROVIDER_ADAPTER_JNDI, DEFAULT_TEST_PROVIDER_ADAPTER_JNDI) ;
+ }
+ }
+
+ public void setDestinationType(final Map<String, String> activationConfig, final boolean queue)
+ throws ConfigurationException
+ {
+ if (queue)
+ {
+ activationConfig.put(TEST_DESTINATION_TYPE, TEST_QUEUE) ;
+ }
+ else
+ {
+ activationConfig.put(TEST_DESTINATION_TYPE, TEST_TOPIC) ;
+ }
+ }
+
+ public void setMessageSelector(final Map<String, String> activationConfig, final String messageSelector)
+ throws ConfigurationException
+ {
+ if (messageSelector != null)
+ {
+ activationConfig.put(TEST_MESSAGE_SELECTOR, messageSelector) ;
+ }
+ else
+ {
+ activationConfig.put(TEST_MESSAGE_SELECTOR, DEFAULT_TEST_MESSAGE_SELECTOR) ;
+ }
+ }
+
+ public void setMaxThreads(final Map<String, String> activationConfig, final Integer maxThreads)
+ throws ConfigurationException
+ {
+ if (maxThreads != null)
+ {
+ activationConfig.put(TEST_MAX_THREADS, maxThreads.toString()) ;
+ }
+ else
+ {
+ activationConfig.put(TEST_MAX_THREADS, DEFAULT_TEST_MAX_THREADS) ;
+ }
+ }
+ }
+
+ public static junit.framework.Test suite ()
+ {
+ return new JUnit4TestAdapter(JmsListenerMapperJCAActivationTest.class);
+ }
+}
Property changes on: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/JmsListenerMapperJCAActivationTest.java
___________________________________________________________________
Name: svn:keywords
+ Rev Date
Name: svn:eol-style
+ native
Added: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_01.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_01.xml (rev 0)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_01.xml 2009-04-26 11:47:09 UTC (rev 26268)
@@ -0,0 +1,24 @@
+<?xml version = "1.0" encoding = "UTF-8"?>
+<jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.0.1.xsd" parameterReloadSecs="5">
+ <providers>
+ <jms-jca-provider name="provider" connection-factory="ConnectionFactory" adapter="jms-ra.rar"
+ providerAdapterJNDI="ProviderAdapterJNDI"> <!-- providerAdapterJNDI -->
+ <jms-bus busid="bus">
+ <!-- destinationType, destination and selector -->
+ <jms-message-filter dest-type="QUEUE" dest-name="DestName" selector="selector"/>
+ </jms-bus>
+ </jms-jca-provider>
+ </providers>
+
+ <services>
+ <service category="category" name="name" description="description">
+ <listeners>
+ <!-- maxThreads -->
+ <jms-listener name="listener" busidref="bus" maxThreads="100"/>
+ <actions mep="OneWay">
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
+ </actions>
+ </listeners>
+ </service>
+ </services>
+</jbossesb>
Property changes on: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_01.xml
___________________________________________________________________
Name: svn:mime-type
+ text/xml
Name: svn:keywords
+ Rev Date
Name: svn:eol-style
+ native
Added: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_02.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_02.xml (rev 0)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_02.xml 2009-04-26 11:47:09 UTC (rev 26268)
@@ -0,0 +1,22 @@
+<?xml version = "1.0" encoding = "UTF-8"?>
+<jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.0.1.xsd" parameterReloadSecs="5">
+ <providers>
+ <jms-jca-provider name="provider" connection-factory="ConnectionFactory">
+ <jms-bus busid="bus">
+ <!-- destinationType and destination-->
+ <jms-message-filter dest-type="TOPIC" dest-name="DestName"/>
+ </jms-bus>
+ </jms-jca-provider>
+ </providers>
+
+ <services>
+ <service category="category" name="name" description="description">
+ <listeners>
+ <jms-listener name="listener" busidref="bus"/>
+ <actions mep="OneWay">
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
+ </actions>
+ </listeners>
+ </service>
+ </services>
+</jbossesb>
Property changes on: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_02.xml
___________________________________________________________________
Name: svn:mime-type
+ text/xml
Name: svn:keywords
+ Rev Date
Name: svn:eol-style
+ native
Added: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_03.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_03.xml (rev 0)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_03.xml 2009-04-26 11:47:09 UTC (rev 26268)
@@ -0,0 +1,24 @@
+<?xml version = "1.0" encoding = "UTF-8"?>
+<jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.0.1.xsd" parameterReloadSecs="5">
+ <providers>
+ <jms-jca-provider name="provider" connection-factory="ConnectionFactory" adapter="test-ra.rar"
+ providerAdapterJNDI="ProviderAdapterJNDI"> <!-- providerAdapterJNDI -->
+ <jms-bus busid="bus">
+ <!-- destinationType, destination and selector -->
+ <jms-message-filter dest-type="QUEUE" dest-name="DestName" selector="selector"/>
+ </jms-bus>
+ </jms-jca-provider>
+ </providers>
+
+ <services>
+ <service category="category" name="name" description="description">
+ <listeners>
+ <!-- maxThreads -->
+ <jms-listener name="listener" busidref="bus" maxThreads="100"/>
+ <actions mep="OneWay">
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
+ </actions>
+ </listeners>
+ </service>
+ </services>
+</jbossesb>
Property changes on: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_03.xml
___________________________________________________________________
Name: svn:mime-type
+ text/xml
Name: svn:keywords
+ Rev Date
Name: svn:eol-style
+ native
Added: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_04.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_04.xml (rev 0)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_04.xml 2009-04-26 11:47:09 UTC (rev 26268)
@@ -0,0 +1,22 @@
+<?xml version = "1.0" encoding = "UTF-8"?>
+<jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.0.1.xsd" parameterReloadSecs="5">
+ <providers>
+ <jms-jca-provider name="provider" connection-factory="ConnectionFactory" adapter="test-ra.rar">
+ <jms-bus busid="bus">
+ <!-- destinationType and destination-->
+ <jms-message-filter dest-type="TOPIC" dest-name="DestName"/>
+ </jms-bus>
+ </jms-jca-provider>
+ </providers>
+
+ <services>
+ <service category="category" name="name" description="description">
+ <listeners>
+ <jms-listener name="listener" busidref="bus"/>
+ <actions mep="OneWay">
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
+ </actions>
+ </listeners>
+ </service>
+ </services>
+</jbossesb>
Property changes on: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_04.xml
___________________________________________________________________
Name: svn:mime-type
+ text/xml
Name: svn:keywords
+ Rev Date
Name: svn:eol-style
+ native
Added: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_05.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_05.xml (rev 0)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_05.xml 2009-04-26 11:47:09 UTC (rev 26268)
@@ -0,0 +1,26 @@
+<?xml version = "1.0" encoding = "UTF-8"?>
+<jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.0.1.xsd" parameterReloadSecs="5">
+ <providers>
+ <jms-jca-provider name="provider" connection-factory="ConnectionFactory"
+ providerAdapterJNDI="ProviderAdapterJNDI"> <!-- providerAdapterJNDI -->
+ <jms-bus busid="bus">
+ <!-- destinationType, destination and selector -->
+ <jms-message-filter dest-type="QUEUE" dest-name="DestName" selector="selector"/>
+ </jms-bus>
+ </jms-jca-provider>
+ </providers>
+
+ <services>
+ <service category="category" name="name" description="description">
+ <listeners>
+ <!-- maxThreads -->
+ <jms-listener name="listener" busidref="bus" maxThreads="100">
+ <property name="jcaActivationMapper" value="org.jboss.soa.esb.listeners.config.mappers.JmsListenerMapperJCAActivationTest$TestActivationMapper"/>
+ </jms-listener>
+ <actions mep="OneWay">
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
+ </actions>
+ </listeners>
+ </service>
+ </services>
+</jbossesb>
Property changes on: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_05.xml
___________________________________________________________________
Name: svn:mime-type
+ text/xml
Name: svn:keywords
+ Rev Date
Name: svn:eol-style
+ native
Added: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_06.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_06.xml (rev 0)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_06.xml 2009-04-26 11:47:09 UTC (rev 26268)
@@ -0,0 +1,24 @@
+<?xml version = "1.0" encoding = "UTF-8"?>
+<jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.0.1.xsd" parameterReloadSecs="5">
+ <providers>
+ <jms-jca-provider name="provider" connection-factory="ConnectionFactory">
+ <jms-bus busid="bus">
+ <!-- destinationType and destination-->
+ <jms-message-filter dest-type="TOPIC" dest-name="DestName"/>
+ </jms-bus>
+ </jms-jca-provider>
+ </providers>
+
+ <services>
+ <service category="category" name="name" description="description">
+ <listeners>
+ <jms-listener name="listener" busidref="bus">
+ <property name="jcaActivationMapper" value="org.jboss.soa.esb.listeners.config.mappers.JmsListenerMapperJCAActivationTest$TestActivationMapper"/>
+ </jms-listener>
+ <actions mep="OneWay">
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
+ </actions>
+ </listeners>
+ </service>
+ </services>
+</jbossesb>
Property changes on: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_06.xml
___________________________________________________________________
Name: svn:mime-type
+ text/xml
Name: svn:keywords
+ Rev Date
Name: svn:eol-style
+ native
Added: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_07.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_07.xml (rev 0)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_07.xml 2009-04-26 11:47:09 UTC (rev 26268)
@@ -0,0 +1,25 @@
+<?xml version = "1.0" encoding = "UTF-8"?>
+<jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.0.1.xsd" parameterReloadSecs="5">
+ <providers>
+ <jms-jca-provider name="provider" connection-factory="ConnectionFactory"
+ providerAdapterJNDI="ProviderAdapterJNDI"> <!-- providerAdapterJNDI -->
+ <jms-bus busid="bus">
+ <property name="jcaActivationMapper" value="org.jboss.soa.esb.listeners.config.mappers.JmsListenerMapperJCAActivationTest$TestActivationMapper"/>
+ <!-- destinationType, destination and selector -->
+ <jms-message-filter dest-type="QUEUE" dest-name="DestName" selector="selector"/>
+ </jms-bus>
+ </jms-jca-provider>
+ </providers>
+
+ <services>
+ <service category="category" name="name" description="description">
+ <listeners>
+ <!-- maxThreads -->
+ <jms-listener name="listener" busidref="bus" maxThreads="100"/>
+ <actions mep="OneWay">
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
+ </actions>
+ </listeners>
+ </service>
+ </services>
+</jbossesb>
Property changes on: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_07.xml
___________________________________________________________________
Name: svn:mime-type
+ text/xml
Name: svn:keywords
+ Rev Date
Name: svn:eol-style
+ native
Added: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_08.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_08.xml (rev 0)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_08.xml 2009-04-26 11:47:09 UTC (rev 26268)
@@ -0,0 +1,23 @@
+<?xml version = "1.0" encoding = "UTF-8"?>
+<jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.0.1.xsd" parameterReloadSecs="5">
+ <providers>
+ <jms-jca-provider name="provider" connection-factory="ConnectionFactory">
+ <jms-bus busid="bus">
+ <property name="jcaActivationMapper" value="org.jboss.soa.esb.listeners.config.mappers.JmsListenerMapperJCAActivationTest$TestActivationMapper"/>
+ <!-- destinationType and destination-->
+ <jms-message-filter dest-type="TOPIC" dest-name="DestName"/>
+ </jms-bus>
+ </jms-jca-provider>
+ </providers>
+
+ <services>
+ <service category="category" name="name" description="description">
+ <listeners>
+ <jms-listener name="listener" busidref="bus"/>
+ <actions mep="OneWay">
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
+ </actions>
+ </listeners>
+ </service>
+ </services>
+</jbossesb>
Property changes on: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_08.xml
___________________________________________________________________
Name: svn:mime-type
+ text/xml
Name: svn:keywords
+ Rev Date
Name: svn:eol-style
+ native
Added: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_09.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_09.xml (rev 0)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_09.xml 2009-04-26 11:47:09 UTC (rev 26268)
@@ -0,0 +1,25 @@
+<?xml version = "1.0" encoding = "UTF-8"?>
+<jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.0.1.xsd" parameterReloadSecs="5">
+ <providers>
+ <jms-jca-provider name="provider" connection-factory="ConnectionFactory"
+ providerAdapterJNDI="ProviderAdapterJNDI"> <!-- providerAdapterJNDI -->
+ <property name="jcaActivationMapper" value="org.jboss.soa.esb.listeners.config.mappers.JmsListenerMapperJCAActivationTest$TestActivationMapper"/>
+ <jms-bus busid="bus">
+ <!-- destinationType, destination and selector -->
+ <jms-message-filter dest-type="QUEUE" dest-name="DestName" selector="selector"/>
+ </jms-bus>
+ </jms-jca-provider>
+ </providers>
+
+ <services>
+ <service category="category" name="name" description="description">
+ <listeners>
+ <!-- maxThreads -->
+ <jms-listener name="listener" busidref="bus" maxThreads="100"/>
+ <actions mep="OneWay">
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
+ </actions>
+ </listeners>
+ </service>
+ </services>
+</jbossesb>
Property changes on: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_09.xml
___________________________________________________________________
Name: svn:mime-type
+ text/xml
Name: svn:keywords
+ Rev Date
Name: svn:eol-style
+ native
Added: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_10.xml
===================================================================
--- labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_10.xml (rev 0)
+++ labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_10.xml 2009-04-26 11:47:09 UTC (rev 26268)
@@ -0,0 +1,23 @@
+<?xml version = "1.0" encoding = "UTF-8"?>
+<jbossesb xmlns="http://anonsvn.labs.jboss.com/labs/jbossesb/trunk/product/etc/schemas/xml/jbossesb-1.0.1.xsd" parameterReloadSecs="5">
+ <providers>
+ <jms-jca-provider name="provider" connection-factory="ConnectionFactory">
+ <property name="jcaActivationMapper" value="org.jboss.soa.esb.listeners.config.mappers.JmsListenerMapperJCAActivationTest$TestActivationMapper"/>
+ <jms-bus busid="bus">
+ <!-- destinationType and destination-->
+ <jms-message-filter dest-type="TOPIC" dest-name="DestName"/>
+ </jms-bus>
+ </jms-jca-provider>
+ </providers>
+
+ <services>
+ <service category="category" name="name" description="description">
+ <listeners>
+ <jms-listener name="listener" busidref="bus"/>
+ <actions mep="OneWay">
+ <action name="testStore" class="org.jboss.soa.esb.actions.StoreMessageToFile"/>
+ </actions>
+ </listeners>
+ </service>
+ </services>
+</jbossesb>
Property changes on: labs/jbossesb/branches/JBESB_4_4_GA_CP/product/rosetta/tests/src/org/jboss/soa/esb/listeners/config/mappers/jbossesb_jca_config_10.xml
___________________________________________________________________
Name: svn:mime-type
+ text/xml
Name: svn:keywords
+ Rev Date
Name: svn:eol-style
+ native
More information about the jboss-svn-commits
mailing list