package com.sitech.jmx.manage;

import com.sitech.base.Config;
import com.sitech.util.mq.JMSSender;
import com.sitech.util.mq.MQConstants;
import org.apache.log4j.Logger;

import javax.jms.DeliveryMode;

/**
 * JMS Producer Manager
 * @author LINXC
 * 2012-12-24
 */
public class MessageSenderManager {
    private static Logger logger = Logger.getLogger(MessageSenderManager.class);

    private JMSSender peformanceDataSender = new JMSSender(
            Config.PERFORMANCE_CONN_URL, Config.Q_PERFORMANCE, DeliveryMode.NON_PERSISTENT);

    private JMSSender alarmDataSender = new JMSSender(
            Config.WORKSTAITON_CONN_URL, Config.Q_WORSTATION);

    private JMSSender rptSender = new JMSSender(
            Config.WORKSTAITON_CONN_URL, MQConstants.Q_ROPORT_FROM_AGENT);

    public void startAllMessageSender() {
        peformanceDataSender.start();
        logger.info("Start Performance Message Producer...");

        alarmDataSender.start();
        logger.info("Start Workstation Message Producer...");

        rptSender.start();
        logger.info("Start BmcServer Message Producer...");
    }
}