jmssendercreditprocess.java

CAS Client Demo学习SSO 的最佳例子

package com.loanapp.service;

import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.Session;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;

import com.loanapp.domain.CreditHistoryBean;


/**
 * @author Administrator
 */
public class JmsSenderCreditProcess {

	private static Log log = LogFactory.getLog(JmsSenderCreditProcess.class);

	private JmsTemplate jmsTemplate;

	/**
	 * @return Returns the jmsTemplate.
	 */
	public JmsTemplate getJmsTemplate() {
		return jmsTemplate;
	}
	/**
	 * @param jmsTemplate The jmsTemplate to set.
	 */
	public void setJmsTemplate(JmsTemplate jmsTemplate) {
		this.jmsTemplate = jmsTemplate;
	}

	public void sendMessage(final CreditHistoryBean creditHistory) {
		jmsTemplate.send(new MessageCreator() {
			public Message createMessage(Session session) throws JMSException {

				MapMessage mapMessage = session.createMapMessage();
				mapMessage.setLong("loanAppId",creditHistory.getLoanAppId());
				mapMessage.setInt("creditScore",creditHistory.getCreditScore());
				mapMessage.setString("creditHistory",creditHistory.getCreditHistory());

				return mapMessage;
			}
		});

	}
}