accountsendsessionbean.java

SOA

/*
 * 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
 */
@Stateless
public 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")
 
}