GenericMessageEndpointManager (Spring Framework API 2.1) - Spring Framework 2.1.0 API 文档英文版

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

The Spring Framework

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.springframework.jca.endpoint
Class GenericMessageEndpointManager

java.lang.Object
  org.springframework.jca.endpoint.GenericMessageEndpointManager

All Implemented Interfaces:: DisposableBean, InitializingBean, Lifecycle

Direct Known Subclasses:: JmsMessageEndpointManager

public class GenericMessageEndpointManager
extends Object
implements InitializingBean, Lifecycle, DisposableBean
extends Object
implements InitializingBean, Lifecycle, DisposableBean

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 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 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 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 provided-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>

Since:: 2.1
Author:: Juergen Hoeller
See Also:: ResourceAdapter.endpointActivation(javax.resource.spi.endpoint.MessageEndpointFactory, javax.resource.spi.ActivationSpec), ResourceAdapter.endpointDeactivation(javax.resource.spi.endpoint.MessageEndpointFactory, javax.resource.spi.ActivationSpec), MessageEndpointFactory, ActivationSpec

Constructor Summary

GenericMessageEndpointManager()


Method Summary

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.

ResourceAdapter getResourceAdapter()
          Return the JCA ResourceAdapter to manage endpoints for.

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 along with this endpoint manager's initialization.

void setMessageEndpointFactory(MessageEndpointFactory messageEndpointFactory)
          Set the JCA MessageEndpointFactory to activate, pointing to a MessageListener object that the endpoints will delegate to.

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Summary
`GenericMessageEndpointManager()`

Method Summary
`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.
`ResourceAdapter`	`getResourceAdapter()` Return the JCA ResourceAdapter to manage endpoints for.
`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 along with this endpoint manager's initialization.
`void`	`setMessageEndpointFactory(MessageEndpointFactory messageEndpointFactory)` Set the JCA MessageEndpointFactory to activate, pointing to a MessageListener object that the endpoints will delegate to.
`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.

Methods inherited from class java.lang.Object
`clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

Constructor Detail

GenericMessageEndpointManager

public GenericMessageEndpointManager()

Method Detail

setResourceAdapter

public void setResourceAdapter(ResourceAdapter resourceAdapter)

Set the JCA ResourceAdapter to manage endpoints for.

getResourceAdapter

public ResourceAdapter getResourceAdapter()

Return the JCA ResourceAdapter to manage endpoints for.

setMessageEndpointFactory

public void setMessageEndpointFactory(MessageEndpointFactory messageEndpointFactory)

Set the JCA MessageEndpointFactory to activate, pointing to a MessageListener object that the endpoints will delegate to.

A MessageEndpointFactory instance may be shared across multiple endpoints (i.e. multiple GenericMessageEndpointManager instances), with different ActivationSpec objects applied.

See Also:: GenericMessageEndpointFactory.setMessageListener(java.lang.Object)

getMessageEndpointFactory

public MessageEndpointFactory getMessageEndpointFactory()

Return the JCA MessageEndpointFactory to activate.

setActivationSpec

public void setActivationSpec(ActivationSpec activationSpec)

Set the JCA ActivationSpec to use for activating the endpoint.

Note that this ActivationSpec instance should not be shared across multiple ResourceAdapter instances.

getActivationSpec

public ActivationSpec getActivationSpec()

Return the JCA ActivationSpec to use for activating the endpoint.

setAutoStartup

public void setAutoStartup(boolean autoStartup)

Set whether to auto-start the endpoint activation along with this endpoint manager's initialization.

Default is "true". Turn this flag off to defer the endpoint activation until an explicit {#start()} call.

afterPropertiesSet

public void afterPropertiesSet()
                        throws ResourceException

Prepares the message endpoint, and automatically activates it if the "autoStartup" flag is set to "true".

Specified by:: afterPropertiesSet in interface InitializingBean

Throws:: ResourceException

start

public void start()

Activates the configured message endpoint.

Specified by:: start in interface Lifecycle

stop

public void stop()

Deactivates the configured message endpoint.

Specified by:: stop in interface Lifecycle

isRunning

public boolean isRunning()

Return whether the configured message endpoint is currently active.

Specified by:: isRunning in interface Lifecycle

Returns:: whether the component is currently running

destroy

public void destroy()

Deactivates the message endpoint, preparing it for shutdown.

Specified by:: destroy in interface DisposableBean