messagehandler.java

BEA WebLogic Server 8.1大全 = BEA webLogic server 8.1 unleashed (美) Mark Artiges等著 袁毅 ... [等] 译 eng

package com.wls8unleashed.jms;

import javax.jms.*;
import java.util.*;

/**
 * MessageHandler provides a common implementation
 * of a message handling method used by these JMS examples.
 */
public class MessageHandler {

	/**
   * Given a JMS message, it prints out its contents.
   */
	public void onMessage(Message message) {
		try {
			// Print information about the message
			System.out.println("\nReceived message...");
			System.out.println(
				"MessageID :"
					+ message.getJMSMessageID()
					+ " for "
					+ message.getJMSDestination());

			System.out.print("Message expiration info: ");
			if (message.getJMSExpiration() > 0) {
				System.out.println(new Date(message.getJMSExpiration()));
			} else {
				System.out.println(" Never expires");
			}

			System.out.println("Priority :" + message.getJMSPriority());

			System.out.println(
				"Mode   : "
					+ (message.getJMSDeliveryMode() == DeliveryMode.PERSISTENT
						? "PERSISTENT"
						: "NON_PERSISTENT"));

			System.out.println("Reply to :      " + message.getJMSReplyTo());

			System.out.println("Message type :  " + message.getJMSType());

			if (message instanceof TextMessage) {
				String receivedMessage = ((TextMessage) message).getText();
				System.out.println("Received text message:" + receivedMessage);

			} else if (message instanceof ObjectMessage) {
				String receivedMessage = message.toString();
        System.out.println("Received object message:" + receivedMessage);				
			}

			System.out.println("\n\n");
		} catch (JMSException jmsException) {
			jmsException.printStackTrace();
		}
	}

}