Spring Framework example source code file (MessageListenerAdapter102.java)

This example Spring Framework source code file (MessageListenerAdapter102.java) is included in the DevDaily.com "Java Source Code Warehouse" project. The intent of this project is to help you "Learn Java by Example" ^TM.

Java - Spring Framework tags/keywords

jmsexception, message, messagelisteneradapter, messagelisteneradapter, messagelisteneradapter102, messagelisteneradapter102, messageproducer, queuesender, queuesession, simplemessageconverter102, simplemessageconverter102, topic, topic, topicsession

The Spring Framework MessageListenerAdapter102.java source code

/*
 * Copyright 2002-2007 the original author or authors.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.springframework.jms.listener.adapter;

import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.Topic;
import javax.jms.TopicPublisher;
import javax.jms.TopicSession;

import org.springframework.jms.support.JmsUtils;
import org.springframework.jms.support.converter.SimpleMessageConverter102;

/**
 * A {@link MessageListenerAdapter} subclass for the JMS 1.0.2 specification,
 * not relying on JMS 1.1 methods like MessageListenerAdapter itself.
 *
 * <p>This class can be used for JMS 1.0.2 providers, offering the same facility
 * as MessageListenerAdapter does for JMS 1.1 providers.
 *
 * @author Juergen Hoeller
 * @author Rick Evans
 * @since 2.0
 */
public class MessageListenerAdapter102 extends MessageListenerAdapter {

	/**
	 * Create a new instance of the {@link MessageListenerAdapter102} class
	 * with the default settings.
	 */
	public MessageListenerAdapter102() {
	}

	/**
	 * Create a new instance of the {@link MessageListenerAdapter102} class
	 * for the given delegate.
	 * @param delegate the target object to delegate message listening to
	 */
	public MessageListenerAdapter102(Object delegate) {
		super(delegate);
	}


	/**
	 * Initialize the default implementations for the adapter's strategies:
	 * SimpleMessageConverter102.
	 * @see #setMessageConverter
	 * @see org.springframework.jms.support.converter.SimpleMessageConverter102
	 */
	protected void initDefaultStrategies() {
		setMessageConverter(new SimpleMessageConverter102());
	}

	/**
	 * Overrides the superclass method to use the JMS 1.0.2 API to send a response.
	 * <p>Uses the JMS pub-sub API if the given destination is a topic,
	 * else uses the JMS queue API.
	 */
	protected void sendResponse(Session session, Destination destination, Message response) throws JMSException {
		MessageProducer producer = null;
		try {
			if (destination instanceof Topic) {
				producer = ((TopicSession) session).createPublisher((Topic) destination);
				postProcessProducer(producer, response);
				((TopicPublisher) producer).publish(response);
			}
			else {
				producer = ((QueueSession) session).createSender((Queue) destination);
				postProcessProducer(producer, response);
				((QueueSender) producer).send(response);
			}
		}
		finally {
			JmsUtils.closeMessageProducer(producer);
		}
	}

}