/**
 * 이 소스는 Spring 프레임워크 워크북에서 사용한 예제 소스입니다. 
 * 이 소스는 모든 개발자들이 자유롭게 수정 및 배포할 수 있습니다. 
 * 단, 이 소스를 기반으로 새로운 애플리케이션을 개발할 경우 출처를 명시해 주시면 됩니다. 
 */
package net.javajigi.advice;

import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.Session;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.aop.ThrowsAdvice;
import org.springframework.beans.factory.BeanCreationException;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.jms.core.JmsTemplate102;
import org.springframework.jms.core.MessageCreator;

public class EmailNotificationThrowsAdvice implements ThrowsAdvice, InitializingBean {
	protected final Log logger = LogFactory.getLog(getClass());
	
	private ConnectionFactory connectionFactory;
	private Queue queue;
	private JmsTemplate102 jmsTemplate;

	public void setQueue(Queue queue) {
		this.queue = queue;
	}
	
	public void setConnectionFactory(ConnectionFactory connectionFactory) {
		this.connectionFactory = connectionFactory;
	}

	public void afterPropertiesSet() throws Exception {
		if (connectionFactory == null) throw new BeanCreationException("Must set connectionFactory");
		if (queue == null) throw new BeanCreationException("Must set queue");
		jmsTemplate = new JmsTemplate102(connectionFactory, false);
	}
	
	public void afterThrowing(final RuntimeException ex) throws Throwable {
		if (logger.isDebugEnabled()) {
			logger.debug("afterThrowing() 시작");
			logger.debug("Caught : " + ex.getClass().getName());
		}

		//mailSender.sendMessage(ex);
		jmsTemplate.send(queue, new MessageCreator() {

			public Message createMessage(Session session) throws JMSException {
				return session.createObjectMessage(ex);
			}
			
		});

		if (logger.isDebugEnabled()) {
			logger.debug("afterThrowing() 종료");
		}
	}
}