jmsmanager.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/01/01   1.0          TriNT      First create       
 */
package jp.co.ntt.awgview.server.jms;

import java.util.ArrayList;

import javax.jms.JMSException;
import javax.naming.NamingException;

import jp.co.ntt.awgview.server.common.LogWriter;
import jp.co.ntt.awgview.server.common.Setting;
import jp.co.ntt.awgview.server.constant.Constants;

/**
 * Class name : JMSManager <BR>
 * 
 * Package : jp.co.ntt_at.awgview.server.jms <BR>
 * 
 * Description : Create and control all JMS Queue of application <BR>
 * 
 * @author : AI&T <BR>
 * @version : 1.0 <BR>
 */
public class JMSManager {

	private static ArrayList<JmsSnmpReplier> lsJMSReplier = null;	
	/**
	 * Start all JMS Queue of Application
	 * 
	 * @throws NamingException
	 * @throws JMSException
	 */
	public void startJMSManager() throws NamingException, JMSException {
		lsJMSReplier = new ArrayList<JmsSnmpReplier>(Setting.MAX_CONNECT);
		for (int i = 1; i <= Setting.MAX_CONNECT; i++) {
			String queueName = Constants.REQUEST_QUEUE_NAME + i;
			JmsSnmpReplier jmsSnmpReplier = JmsSnmpReplier.newReplier(queueName);
			lsJMSReplier.add(jmsSnmpReplier);
			LogWriter.getSNMPLogger().info("Start JMS replier with Queue name = " + (Constants.REQUEST_QUEUE_NAME + i));			
		}
	}
	
	/***
	 * Stop all JMS Queue of Application
	 * 
	 * @throws Exception
	 */
	public void stopJMSManager() throws Exception {
		try{
			LogWriter.getSNMPLogger().info("JMS manager closed clean");		
			if (lsJMSReplier == null) {
				return;
			}
			
			int len = lsJMSReplier.size();
			for (int i = 0; i < len; i++) {
				JmsSnmpReplier jmsSnmpReplier = lsJMSReplier.get(i);
				if (jmsSnmpReplier != null) {
					jmsSnmpReplier.doDisconnect();
				}
			}			
			System.gc();
		}catch (Exception e){
			LogWriter.getSNMPLogger().info(e.toString());
		}
	}
}