package org.argeo.slc.demo.manager;

import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.xbean.spring.context.ClassPathXmlApplicationContext;
import org.springframework.beans.BeansException;
import org.springframework.jms.JmsException;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

public class JmsTesting {
	private final static Log log = LogFactory.getLog(JmsTesting.class);

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext(
				"conf/jms.xml");
		try {

			ConnectionFactory connectionFactory = (ConnectionFactory) applicationContext
					.getBean("slcDefault.jms.connectionFactory");
			JmsTemplate jmsTemplate = new JmsTemplate(connectionFactory);

			jmsTemplate.send("modulesManager.request", new MessageCreator() {

				public Message createMessage(Session session)
						throws JMSException {
					TextMessage message = session.createTextMessage();
					message.setStringProperty("action",
							"getExecutionModuleDescriptor");
					message.setStringProperty("name",
							"org.argeo.slc.demo.basic");
					message.setStringProperty("version", "LATEST");
					return message;
				}
			});

			TextMessage message = (TextMessage) jmsTemplate
					.receive("modulesManager.response");
			log.info("Received message: " + message.getText() + "\n");

		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			applicationContext.close();
		}
	}

}