package com.samsung.fpoc.jms;

import java.sql.SQLException;

import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.MessageListener;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import org.jboss.fpoc.dao.LotDAO;
import org.jboss.fpoc.model.Lot;


@Service("notificationsConsumer")
public class LotMessageListener implements MessageListener {
	private static final Logger log = Logger.getLogger(LotMessageListener.class);
	
	@Autowired
	private Queue logManagerQueue;

	@Autowired
	private ConnectionFactory inVMConnectionFactory;
	
	@Autowired
	private LotDAO lotDao;

	private Connection notificationsQueueConnection;

	@PostConstruct
	public void init() throws Exception {
		log.info("LotMessageListener is preparing");
		notificationsQueueConnection = inVMConnectionFactory.createConnection();
		Session notificationsQueueSession = notificationsQueueConnection
				.createSession(false, Session.AUTO_ACKNOWLEDGE);
		MessageConsumer notificationsQueueConsumer = notificationsQueueSession
				.createConsumer(logManagerQueue);
		notificationsQueueConsumer.setMessageListener(this);
		notificationsQueueConnection.start();
		log.info("LotMessageListener is started");		
	}

	@PreDestroy
	public void destroy() throws Exception {
		if (notificationsQueueConnection != null)
			notificationsQueueConnection.close();
	}
	
	public void onMessage(Message message) {
		if (message instanceof TextMessage) {
			try {
				String lotId = ((TextMessage) message).getText();
				System.out.println("The Lot Request Message is : \n" + lotId);
				Lot lot = null;
				try {
					lot = lotDao.selectLot(lotId);
				} catch (SQLException e) {
					e.printStackTrace();
				}
				log.info("RESULT : " + lot);
			} catch (JMSException ex) {
				throw new RuntimeException(ex);
			}
		} else {
			throw new IllegalArgumentException(
					"Message must be of type TextMessage");
		}
	}

	
	

}

import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.jms.Message;
import javax.jms.MessageListener;

import org.jboss.ejb3.annotation.Depends;

/**
 * Message-Driven Bean implementation class for: LotManagerMDB
 *
 */
@MessageDriven(activationConfig =
{
@ActivationConfigProperty(propertyName="destinationType", propertyValue="javax.jms.Queue"),
@ActivationConfigProperty(propertyName="destination", propertyValue="/queue/LotManagerQueue")
})
@Depends("org.hornetq:module=JMS,name=\"LotManagerQueue\",type=Queue")
public class LotManagerMDB implements MessageListener {
	
    /**
     * Default constructor. 
     */
    public LotManagerMDB() {
        // TODO Auto-generated constructor stub
    }
	
	/**
     * @see MessageListener#onMessage(Message)
     */
    public void onMessage(Message message) {
    	System.out.println("==============================");
    	System.out.println("MESSAGE : " + message);
    	System.out.println("==============================");
    }

}

import org.apache.log4j.Logger;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.impl.StdSchedulerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Service;


@Service
public class QuartzFactory {
	private static final Logger log = Logger.getLogger(QuartzFactory.class);
	
	private StdSchedulerFactory factory;
	private Scheduler scheduler = null;
	
	
	public QuartzFactory() throws SchedulerException {
		factory = new StdSchedulerFactory();
		start();
	}
	
	
	public Scheduler getScheduler() {
		try {
			if( scheduler != null && scheduler.isStarted() ) return scheduler;
		} catch (SchedulerException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return null;
	}
	
	public void start() {
		try {
			if( scheduler == null )
				scheduler = factory.getScheduler();
			//if( scheduler != null && !scheduler.isStarted())
			log.info("-------------- Scheduler Setup Complete -----------------");
			if( scheduler != null && !scheduler.isStarted())
				scheduler.start();
			log.info("-------------- Scheduler Startup Complete -----------------");
		} catch (SchedulerException e) {
			e.printStackTrace();
		}
	}
	
	public void restart() {
		try {
			if( scheduler == null ) {
				//schedulerFactory();
				start();
			}
		}catch(Exception e) {
			e.printStackTrace();
		}
	}
	
	
	public void shutdown() {
		try {
			if( scheduler != null && !scheduler.isShutdown()) {
				log.info("------- Shutting Down ---------------------");
				scheduler.shutdown(true);
				scheduler = null;
				log.info("------- Shutdown Complete -----------------");
			}
		} catch (SchedulerException e) {
			e.printStackTrace();
		}
	}
}