/* * To change this template, choose Tools | Templates * and open the template in the editor. */package com.sysu.service;import com.sysu.pojo.Account;import java.util.logging.Level;import java.util.logging.Logger;import javax.annotation.Resource;import javax.ejb.Stateless;import javax.jms.Connection;import javax.jms.ConnectionFactory;import javax.jms.JMSException;import javax.jms.MessageProducer;import javax.jms.ObjectMessage;import javax.jms.Queue;import javax.jms.Session;/** * * @author Levi Wong */@Statelesspublic class AccountSendSessionBean implements AccountSendSessionRemote {    @Resource(name = "jms/AccountMessage")    private Queue accountMessage;    @Resource(name = "jms/AccountMessageFactory")    private ConnectionFactory accountMessageFactory;    private ObjectMessage createJMSMessageForjmsAccountMessage(Session session, Object messageData) throws JMSException {        // TODO create and populate message to send        ObjectMessage tm = session.createObjectMessage();        tm.setObject((Account) messageData);        return tm;    }    private void sendJMSMessageToAccountMessage(Object messageData) throws JMSException {        Connection connection = null;        Session session = null;        try {            connection = accountMessageFactory.createConnection();            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);            MessageProducer messageProducer = session.createProducer(accountMessage);            messageProducer.send(createJMSMessageForjmsAccountMessage(session, messageData));        } finally {            if (session != null) {                try {                    session.close();                } catch (JMSException e) {                    Logger.getLogger(this.getClass().getName()).log(Level.WARNING, "Cannot close session", e);                }            }            if (connection != null) {                connection.close();            }        }    }    public void createAccount(String accountNum, String accountPassword, int balance) {        Account acc = new Account();        acc.setAccountNum(accountNum);        acc.setAccountPassword(accountPassword);        acc.setBalance(balance);        try {            sendJMSMessageToAccountMessage(acc);        } catch (JMSException ex) {            Logger.getLogger(AccountSendSessionBean.class.getName()).log(Level.SEVERE, null, ex);        }    }        // Add business logic below. (Right-click in editor and choose    // "Insert Code > Add Business Method" or "Web Service > Add Operation") }