org.figure8.join.core.messaging
Class JMSConsumerEndpointFactory

java.lang.Object
  org.jencks.EndpointFactorySupport
      org.figure8.join.core.messaging.JMSConsumerEndpointFactory

All Implemented Interfaces:

javax.resource.spi.endpoint.MessageEndpointFactory

public class JMSConsumerEndpointFactory
extends org.jencks.EndpointFactorySupport

This is an implementation of JCA MessageEndpointFactory creating MessageEndpoint from bean wrapping information on a JMSConsumerBean.
This factory takes care if consumer is thread safe or not.

Version:

$Revision: 1.2 $

Author:

Laurent Broudoux

See Also:

MessageEndpointFactory

Field Summary

Fields inherited from class org.jencks.EndpointFactorySupport

transactionManager

Constructor Summary

JMSConsumerEndpointFactory(JMSConsumerBeanInfo consumerInfo)
Creates a new JMSConsumerEndpointFactory with consumer info.

JMSConsumerEndpointFactory(JMSConsumerBeanInfo consumerInfo, javax.transaction.TransactionManager transactionManager)
Creates a new JMSConsumerEndpointFactory with consumer info and a transaction manager.

Method Summary

protected javax.jms.MessageListener	createMessageListener() Implementation of EndpointFactorySupport.
JMSConsumerBeanInfo	getConsumerInfo()
void	setConsumerInfo(JMSConsumerBeanInfo consumerInfo)

Methods inherited from class org.jencks.EndpointFactorySupport

createEndpoint, getTransactionManager, isDeliveryTransacted, setTransactionManager, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

JMSConsumerEndpointFactory

public JMSConsumerEndpointFactory(JMSConsumerBeanInfo consumerInfo)

Creates a new JMSConsumerEndpointFactory with consumer info.

Parameters:

consumerInfo - The bean wrapping information on a JMSConsumerBean

JMSConsumerEndpointFactory

public JMSConsumerEndpointFactory(JMSConsumerBeanInfo consumerInfo,
                                  javax.transaction.TransactionManager transactionManager)

Creates a new JMSConsumerEndpointFactory with consumer info and a transaction manager.

Parameters:

consumerInfo - The bean wrapping information on a JMSConsumerBean

transactionManager - TransactionManager for creating inbound JCA connector

Method Detail

getConsumerInfo

public JMSConsumerBeanInfo getConsumerInfo()

Returns:

The bean wrapping information on a JMSConsumerBean

setConsumerInfo

public void setConsumerInfo(JMSConsumerBeanInfo consumerInfo)

Parameters:

consumerInfo - The bean wrapping information on a JMSConsumerBean

createMessageListener

protected javax.jms.MessageListener createMessageListener()
                                                   throws javax.resource.spi.UnavailableException

Implementation of EndpointFactorySupport. This method deals with the creation of message listener that will be used as a JCA endpoint. Depending on the thread safetyness of the consumer, it may be wrapped into a pooling proxy.

Specified by:

createMessageListener in class org.jencks.EndpointFactorySupport

Returns:

The newly created message listener implementation

Throws:

javax.resource.spi.UnavailableException - if consumer cannot be created