jms11unifiedtransactionexample.java

全面解析jms源码

package jms11;

import javax.naming.*;  // The JNDI classes         
import javax.jms.*;     // The JMS 1.1 classes

public class JMS11UnifiedTransactionExample {

    /**
     * Transfer a message from a source destination
     * to a target destination. The destinations may
     * both be queues, both be topics, or may be from a
     * queue to a topic, or from a topic to a queue.
     */
    public void transferMessage(String connectionFactoryName, String sourceName, String targetName)
        throws NamingException, JMSException {

        // Get the specified connection factory and destinations
        Context jndiContext = new InitialContext();
        ConnectionFactory factory = (ConnectionFactory)
            jndiContext.lookup(connectionFactoryName);
        Destination source = (Destination) jndiContext.lookup(sourceName);
        Destination target = (Destination) jndiContext.lookup(targetName);

        // Create the connection and session
        Connection connection = factory.createConnection();
        Session session = connection.createSession(true,
            Session.AUTO_ACKNOWLEDGE);

        // Use the session and destinations to
        // create the consumer and producer
        MessageConsumer consumer = session.createConsumer(source);
        MessageProducer producer = session.createProducer(target);

        // Transfer the next message on the source 
        // destination to the target destination
        // in a single transaction
        try {
            producer.send(consumer.receive());
            session.commit();
        }
        catch (JMSException ex) {
            session.rollback();
        }

        // Release all resources
        producer.close();
        consumer.close();
        session.close();
        connection.close();
    }
}