org.mule.transport.jms

Class Jms11Support

java.lang.Object

org.mule.transport.jms.Jms11Support

All Implemented Interfaces:

JmsSupport

Direct Known Subclasses:

Jms102bSupport

public class Jms11Support
extends Object
implements JmsSupport

Jms11Support is a template class to provide an abstraction to to the JMS 1.1 API specification.

Field Summary

Fields

Modifier and Type	Field and Description
protected JmsConnector	connector
protected Log	logger logger used by this class

Constructor Summary

Constructors

Constructor and Description
Jms11Support(JmsConnector connector)

Method Summary

Methods

Modifier and Type	Method and Description
Connection	createConnection(ConnectionFactory connectionFactory)
Connection	createConnection(ConnectionFactory connectionFactory, String username, String password)
MessageConsumer	createConsumer(Session session, Destination destination, boolean topic, ImmutableEndpoint endpoint)
MessageConsumer	createConsumer(Session session, Destination destination, String messageSelector, boolean noLocal, String durableName, boolean topic, ImmutableEndpoint endpoint)
Destination	createDestination(Session session, ImmutableEndpoint endpoint)
Destination	createDestination(Session session, String name, boolean topic, ImmutableEndpoint endpoint)
MessageProducer	createProducer(Session session, Destination destination, boolean topic)
Session	createSession(Connection connection, boolean topic, boolean transacted, int ackMode, boolean noLocal)
Destination	createTemporaryDestination(Session session, boolean topic)
protected Destination	getJndiDestination(String name)
boolean	isCacheJmsSessions()
void	send(MessageProducer producer, Message message, boolean topic, ImmutableEndpoint endpoint)
void	send(MessageProducer producer, Message message, boolean persistent, int priority, long ttl, boolean topic, ImmutableEndpoint endpoint)
void	send(MessageProducer producer, Message message, Destination dest, boolean topic, ImmutableEndpoint endpoint)
void	send(MessageProducer producer, Message message, Destination dest, boolean persistent, int priority, long ttl, boolean topic, ImmutableEndpoint endpoint)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final Log logger

logger used by this class

connector

protected JmsConnector connector

Constructor Detail

Jms11Support

public Jms11Support(JmsConnector connector)

Method Detail

isCacheJmsSessions

public boolean isCacheJmsSessions()

Specified by:

isCacheJmsSessions in interface JmsSupport

Returns:

whether to cache and re-use the JMS session and producer object instead of recreating them for each request.

createConnection

public Connection createConnection(ConnectionFactory connectionFactory,
                          String username,
                          String password)
                            throws JMSException

Specified by:

createConnection in interface JmsSupport

Throws:

JMSException

createConnection

public Connection createConnection(ConnectionFactory connectionFactory)
                            throws JMSException

Specified by:

createConnection in interface JmsSupport

Throws:

JMSException

createSession

public Session createSession(Connection connection,
                    boolean topic,
                    boolean transacted,
                    int ackMode,
                    boolean noLocal)
                      throws JMSException

Specified by:

createSession in interface JmsSupport

Throws:

JMSException

createProducer

public MessageProducer createProducer(Session session,
                             Destination destination,
                             boolean topic)
                               throws JMSException

Specified by:

createProducer in interface JmsSupport

Throws:

JMSException

createConsumer

public MessageConsumer createConsumer(Session session,
                             Destination destination,
                             boolean topic,
                             ImmutableEndpoint endpoint)
                               throws JMSException

Specified by:

createConsumer in interface JmsSupport

Throws:

JMSException

createConsumer

public MessageConsumer createConsumer(Session session,
                             Destination destination,
                             String messageSelector,
                             boolean noLocal,
                             String durableName,
                             boolean topic,
                             ImmutableEndpoint endpoint)
                               throws JMSException

Specified by:

createConsumer in interface JmsSupport

Throws:

JMSException

createDestination

public Destination createDestination(Session session,
                            ImmutableEndpoint endpoint)
                              throws JMSException

Specified by:

createDestination in interface JmsSupport

Throws:

JMSException

createDestination

public Destination createDestination(Session session,
                            String name,
                            boolean topic,
                            ImmutableEndpoint endpoint)
                              throws JMSException

Specified by:

createDestination in interface JmsSupport

Throws:

JMSException

getJndiDestination

protected Destination getJndiDestination(String name)
                                  throws JMSException

Throws:

JMSException

createTemporaryDestination

public Destination createTemporaryDestination(Session session,
                                     boolean topic)
                                       throws JMSException

Specified by:

createTemporaryDestination in interface JmsSupport

Throws:

JMSException

send

public void send(MessageProducer producer,
        Message message,
        boolean topic,
        ImmutableEndpoint endpoint)
          throws JMSException

Specified by:

send in interface JmsSupport

Throws:

JMSException

send

public void send(MessageProducer producer,
        Message message,
        Destination dest,
        boolean topic,
        ImmutableEndpoint endpoint)
          throws JMSException

Specified by:

send in interface JmsSupport

Throws:

JMSException

send

public void send(MessageProducer producer,
        Message message,
        boolean persistent,
        int priority,
        long ttl,
        boolean topic,
        ImmutableEndpoint endpoint)
          throws JMSException

Specified by:

send in interface JmsSupport

Throws:

JMSException

send

public void send(MessageProducer producer,
        Message message,
        Destination dest,
        boolean persistent,
        int priority,
        long ttl,
        boolean topic,
        ImmutableEndpoint endpoint)
          throws JMSException

Specified by:

send in interface JmsSupport

Throws:

JMSException