package com.silverisland.servlet.listener;

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;

import org.apache.activemq.broker.BrokerService;

public class ActiveMQBrokerStartListener implements ServletContextListener {

	BrokerService broker = new BrokerService();
	
	public void contextInitialized(ServletContextEvent arg0) {
        try{
        	broker.addConnector("tcp://localhost:61616?trace=true");
        	broker.start();
        }catch(Exception e){
        	System.err.println(e.getMessage());
        	e.printStackTrace();
        	throw new RuntimeException(e);
        }
	}

	public void contextDestroyed(ServletContextEvent arg0) {
		try{
			broker.stop();
		}catch(Exception e){
			System.err.println(e.getMessage());
			e.printStackTrace();
        	throw new RuntimeException(e);
        }
	}

}