objectmessagecreator.java.svn-base

this is example use EJB with jboss.

/*
 * Copyright(C) 2008, NTT AT Co., Ltd.
 * Project: AWGView
 *
 * Notes:
 *  N/A
 *
 * Record of change:
 * Date         Version      Name       Content
 * 2008/12/15   1.0          TriNT      First create       
 */
package jp.co.ntt.awgview.server.jms;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.ObjectMessage;
import javax.jms.Session;

import jp.co.ntt.awgview.server.common.LogWriter;
import jp.co.ntt.awgview.server.common.Utils;
import jp.co.ntt.awgview.server.vo.SnmpVO;
import jp.co.ntt.awgview.server.vo.TrapVO;

/**
 * Class name 	: ObjectMessageCreator <BR>
 * 
 * Package 		: jp.co.ntt_at.awgview.server.jms <BR>
 * 
 * Description	: Create ObjectMessage.
 * 				  ObjectMessage object is used to send a message 
 *                that contains a serializable object in the Java programming language <BR>
 * 
 * @author 		: AI&T
 * @version 	: 1.0
 */
public class ObjectMessageCreator {	

	/**
	 * Creates an Object Message object.
	 * 
	 * @param session
	 * @param trapVO
	 * @return Message
	 */
	public Message createObjectMessage(Session session, TrapVO trapVO) throws JMSException{

		ObjectMessage objMsg = null;
		try {
			objMsg = session.createObjectMessage();
			objMsg.setObject(trapVO);
		} catch (Exception ex) {			
			LogWriter.getSNMPLogger().error("Caught exception while creating message: " + ex);
			if (LogWriter.getSNMPLogger().isTraceEnabled()) {
				LogWriter.getSNMPLogger().trace(Utils.parseException(ex));
			}
		}
		return (objMsg);
	}

	/**
	 * Creates an ObjectMessage object.
	 * 
	 * @param session
	 * @param snmpVO
	 * @param requestJMSMessageID
	 * @return Message
	 */
	public Message createObjectMessage(Session session, SnmpVO snmpVO, String requestJMSMessageID) {

		ObjectMessage objMsg = null;
		try {
			objMsg = session.createObjectMessage();			
			objMsg.setJMSCorrelationID(requestJMSMessageID);			
			snmpVO.setJmsCorrelID(requestJMSMessageID);	
			
			objMsg.setObject(snmpVO);
		} catch (Exception ex) {
			LogWriter.getSNMPLogger().error("Caught exception while creating message: " + ex);
			if (LogWriter.getSNMPLogger().isTraceEnabled()) {
				LogWriter.getSNMPLogger().trace(Utils.parseException(ex));
			}
		}
		return (objMsg);
	}	
}