Class JmsMessageEndpointFactory

java.lang.Object

org.springframework.jca.endpoint.AbstractMessageEndpointFactory

org.springframework.jms.listener.endpoint.JmsMessageEndpointFactory

All Implemented Interfaces:

jakarta.resource.spi.endpoint.MessageEndpointFactory, Aware, BeanNameAware

public class JmsMessageEndpointFactory
extends AbstractMessageEndpointFactory

JMS-specific implementation of the JCA 1.7 MessageEndpointFactory interface, providing transaction management capabilities for a JMS listener object (for example, a MessageListener object).

Uses a static endpoint implementation, simply wrapping the specified message listener object and exposing all of its implemented interfaces on the endpoint instance.

Typically used with Spring's JmsMessageEndpointManager, but not tied to it. As a consequence, this endpoint factory could also be used with programmatic endpoint management on a native ResourceAdapter instance.

Since:

2.5

Author:

Juergen Hoeller, Stephane Nicoll

See Also:

• setMessageListener(MessageListener)
• AbstractMessageEndpointFactory.setTransactionManager(Object)
• JmsMessageEndpointManager

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JmsMessageEndpointFactory.JmsResourceException	Internal exception thrown when a ResourceException has been encountered during the endpoint invocation.

Nested classes/interfaces inherited from class AbstractMessageEndpointFactory

AbstractMessageEndpointFactory.AbstractMessageEndpoint

Field Summary

Fields inherited from class AbstractMessageEndpointFactory

logger

Constructor Summary

Constructors

Constructor	Description
JmsMessageEndpointFactory()

Method Summary

Modifier and Type	Method	Description
protected AbstractMessageEndpointFactory.AbstractMessageEndpoint	createEndpointInternal()	Creates a concrete JMS message endpoint, internal to this factory.
protected jakarta.jms.MessageListener	getMessageListener()	Return the JMS MessageListener for this endpoint.
void	setMessageListener(jakarta.jms.MessageListener messageListener)	Set the JMS MessageListener for this endpoint.

Methods inherited from class AbstractMessageEndpointFactory

createEndpoint, createEndpoint, getActivationName, getEndpointClass, isDeliveryTransacted, setBeanName, setTransactionFactory, setTransactionManager, setTransactionName, setTransactionTimeout

Methods inherited from class Object

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

Constructor Details

JmsMessageEndpointFactory

public JmsMessageEndpointFactory()

Method Details

setMessageListener

public void setMessageListener(jakarta.jms.MessageListener messageListener)

Set the JMS MessageListener for this endpoint.

getMessageListener

protected jakarta.jms.MessageListener getMessageListener()

Return the JMS MessageListener for this endpoint.

createEndpointInternal

protected AbstractMessageEndpointFactory.AbstractMessageEndpoint createEndpointInternal()
                                                                                 throws jakarta.resource.spi.UnavailableException

Creates a concrete JMS message endpoint, internal to this factory.

Specified by:

createEndpointInternal in class AbstractMessageEndpointFactory

Returns:

the actual endpoint instance (never null)

Throws:

jakarta.resource.spi.UnavailableException - if no endpoint is available at present