GenericMessageEndpointManager

Class Overview

Generic bean that manages JCA 1.5 message endpoints within a Spring application context, activating and deactivating the endpoint as part of the application context's lifecycle.

This class is completely generic in that it may work with any ResourceAdapter, any MessageEndpointFactory, and any ActivationSpec. It can be configured in standard bean style, for example through Spring's XML bean definition format, as follows:

 <bean class="org.springframework.jca.endpoint.GenericMessageEndpointManager">
 	 <property name="resourceAdapter" ref="resourceAdapter"/>
 	 <property name="messageEndpointFactory">
     <bean class="org.springframework.jca.endpoint.GenericMessageEndpointFactory">
       <property name="messageListener" ref="messageListener"/>
     </bean>
 	 </property>
 	 <property name="activationSpec">
     <bean class="org.apache.activemq.ra.ActiveMQActivationSpec">
       <property name="destination" value="myQueue"/>
       <property name="destinationType" value="javax.jms.Queue"/>
     </bean>
   </property>
 </bean>

In this example, Spring's own GenericMessageEndpointFactory is used to point to a standard message listener object that happens to be supported by the specified target ResourceAdapter: in this case, a JMS javax.jms.MessageListener object as supported by the ActiveMQ message broker, defined as a Spring bean:

 <bean id="messageListener" class="com.myorg.messaging.myMessageListener">
   ...
 </bean>

The target ResourceAdapter may be configured as a local Spring bean as well (the typical case) or obtained from JNDI (e.g. on WebLogic). For the example above, a local ResourceAdapter bean could be defined as follows (matching the "resourceAdapter" bean reference above):

 <bean id="resourceAdapter" class="org.springframework.jca.support.ResourceAdapterFactoryBean">
   <property name="resourceAdapter">
     <bean class="org.apache.activemq.ra.ActiveMQResourceAdapter">
       <property name="serverUrl" value="tcp://localhost:61616"/>
     </bean>
   </property>
   <property name="workManager">
     <bean class="org.springframework.jca.work.SimpleTaskWorkManager"/>
   </property>
 </bean>

For a different target resource, the configuration would simply point to a different ResourceAdapter and a different ActivationSpec object (which are both specific to the resource provider), and possibly a different message listener (e.g. a CCI javax.resource.cci.MessageListener for a resource adapter which is based on the JCA Common Client Interface).

The asynchronous execution strategy can be customized through the "workManager" property on the ResourceAdapterFactoryBean (as shown above). Check out SimpleTaskWorkManager's javadoc for its configuration options; alternatively, any other JCA-compliant WorkManager can be used (e.g. Geronimo's).

Transactional execution is a responsibility of the concrete message endpoint, as built by the specified MessageEndpointFactory. GenericMessageEndpointFactory supports XA transaction participation through its "transactionManager" property, typically with a Spring JtaTransactionManager or a plain javax.transaction.TransactionManager implementation specified there.

 <bean class="org.springframework.jca.endpoint.GenericMessageEndpointManager">
 	 <property name="resourceAdapter" ref="resourceAdapter"/>
 	 <property name="messageEndpointFactory">
     <bean class="org.springframework.jca.endpoint.GenericMessageEndpointFactory">
       <property name="messageListener" ref="messageListener"/>
       <property name="transactionManager" ref="transactionManager"/>
     </bean>
 	 </property>
 	 <property name="activationSpec">
     <bean class="org.apache.activemq.ra.ActiveMQActivationSpec">
       <property name="destination" value="myQueue"/>
       <property name="destinationType" value="javax.jms.Queue"/>
     </bean>
   </property>
 </bean>

 <bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager"/>

Alternatively, check out your resource provider's ActivationSpec object, which should support local transactions through a provider-specific config flag, e.g. ActiveMQActivationSpec's "useRAManagedTransaction" bean property.

 <bean class="org.springframework.jca.endpoint.GenericMessageEndpointManager">
 	 <property name="resourceAdapter" ref="resourceAdapter"/>
 	 <property name="messageEndpointFactory">
     <bean class="org.springframework.jca.endpoint.GenericMessageEndpointFactory">
       <property name="messageListener" ref="messageListener"/>
     </bean>
 	 </property>
 	 <property name="activationSpec">
     <bean class="org.apache.activemq.ra.ActiveMQActivationSpec">
       <property name="destination" value="myQueue"/>
       <property name="destinationType" value="javax.jms.Queue"/>
       <property name="useRAManagedTransaction" value="true"/>
     </bean>
   </property>
 </bean>

Summary

Public Constructors
	GenericMessageEndpointManager()

Public Methods
void	afterPropertiesSet() Prepares the message endpoint, and automatically activates it if the "autoStartup" flag is set to "true".
void	destroy() Deactivates the message endpoint, preparing it for shutdown.
ActivationSpec	getActivationSpec() Return the JCA ActivationSpec to use for activating the endpoint.
MessageEndpointFactory	getMessageEndpointFactory() Return the JCA MessageEndpointFactory to activate.
int	getPhase() Return the phase in which this endpoint manager will be started and stopped.
ResourceAdapter	getResourceAdapter() Return the JCA ResourceAdapter to manage endpoints for.
boolean	isAutoStartup() Return the value for the 'autoStartup' property.
boolean	isRunning() Return whether the configured message endpoint is currently active.
void	setActivationSpec(ActivationSpec activationSpec) Set the JCA ActivationSpec to use for activating the endpoint.
void	setAutoStartup(boolean autoStartup) Set whether to auto-start the endpoint activation after this endpoint manager has been initialized and the context has been refreshed.
void	setMessageEndpointFactory(MessageEndpointFactory messageEndpointFactory) Set the JCA MessageEndpointFactory to activate, pointing to a MessageListener object that the endpoints will delegate to.
void	setPhase(int phase) Specify the phase in which this endpoint manager should be started and stopped.
void	setResourceAdapter(ResourceAdapter resourceAdapter) Set the JCA ResourceAdapter to manage endpoints for.
void	start() Activates the configured message endpoint.
void	stop() Deactivates the configured message endpoint.
void	stop(Runnable callback) Indicates that a Lifecycle component must stop if it is currently running.

[Expand] Inherited Methods
From class java.lang.Object Object clone() boolean equals(Object arg0) void finalize() final Class<?> getClass() int hashCode() final void notify() final void notifyAll() String toString() final void wait() final void wait(long arg0, int arg1) final void wait(long arg0)
From interface org.springframework.beans.factory.DisposableBean abstract void destroy() Invoked by a BeanFactory on destruction of a singleton.
From interface org.springframework.beans.factory.InitializingBean abstract void afterPropertiesSet() Invoked by a BeanFactory after it has set all bean properties supplied (and satisfied BeanFactoryAware and ApplicationContextAware).
From interface org.springframework.context.Lifecycle abstract boolean isRunning() Check whether this component is currently running. abstract void start() Start this component. abstract void stop() Stop this component.
From interface org.springframework.context.Phased abstract int getPhase() Return the phase value of this object.
From interface org.springframework.context.SmartLifecycle abstract boolean isAutoStartup() Return whether this Lifecycle component should be started automatically by the container when the ApplicationContext is refreshed. abstract void stop(Runnable callback) Indicates that a Lifecycle component must stop if it is currently running.