advertisebean.java

21天学通J2EE的例子4

package agency;

import java.rmi.*;
import java.sql.*;
import java.util.*;
import javax.ejb.*;
import javax.jms.JMSException ;
import javax.naming.* ;
import javax.sql.*;

import data.*;

public class AdvertiseBean implements SessionBean
{
    private JobLocalHome jobHome;
    private CustomerLocalHome customerHome;
    private CustomerLocal customer;
    private MessageSender messageSender;

    public void updateDetails (String name, String email, String[] address) {
        customer.setName(name);
        customer.setEmail(email);
        customer.setAddress(address);
    }
    
    public String getLogin() {
        return customer.getLogin();
    }

    public String getName() {
        return customer.getName();
    }

    public String getEmail() {
        return customer.getEmail();
    }

    public String[] getAddress() {
        return customer.getAddress();
    }

    public String[] getJobs() {
        try {
            Collection col = jobHome.findByCustomer(customer.getLogin());
            String[] res = new String[col.size()];
            Iterator it = col.iterator();
            int i = 0;
            while (it.hasNext()) {
                JobLocal job = (JobLocal)it.next();
                res[i++] = job.getRef();
            }
            return (res);
        }
        catch (FinderException ex) {
            error("Cannot find jobs for customer: "+customer.getLogin(),ex);
        }
        return null;
    }

    public void createJob (String ref) throws DuplicateException, CreateException {
        try {
            jobHome.create(ref,customer.getLogin());
            messageSender.sendJob(ref,customer.getLogin(),true);
        }
        catch (JMSException ex) {
            error ("Error sending job match message",ex);
         }
        catch (CreateException ex) {
            error("Cannot create job: "+ref,ex);
        }
    }

    public void deleteJob (String ref) throws NotFoundException {
        try {
            jobHome.remove(new JobPK(ref,customer.getLogin()));
            messageSender.sendJob(ref,customer.getLogin(),false);
        }
        catch (JMSException ex) {
            error ("Error sending job match message",ex);
         }
        catch (RemoveException ex) {
            error("Cannot remove job: "+ref,ex);
        }
    }

    private void error (String msg, Exception ex) {
        String s = "AdvertiseBean: "+msg + "\n" + ex;
        System.out.println(s);
        throw new EJBException(s, ex);
    }

    // EJB methods start here

    public void ejbCreate (String login) throws CreateException {
        try {
            customer = customerHome.findByPrimaryKey(login);
        }
        catch (FinderException ex) {
            error("Cannot find customer: "+login,ex);
        }
    }

    public void ejbActivate(){
    }

    public void ejbPassivate(){
    }

    public void ejbRemove(){
        try {
            messageSender.close();
        }
        catch (JMSException ex) {
            error("Error closing down the queue",ex);
        }
    }

    private SessionContext ctx;
    
    public void setSessionContext(SessionContext ctx) {
        this.ctx = ctx;
        InitialContext ic=null;
        try {
            ic = new InitialContext();
            customerHome = (CustomerLocalHome)ic.lookup("java:comp/env/ejb/CustomerLocal");
            jobHome = (JobLocalHome)ic.lookup("java:comp/env/ejb/JobLocal");
            messageSender = new MessageSender("java:comp/env/jms/QueueConnectionFactory","java:comp/env/jms/jobQueue");
        }
        catch (NamingException ex) {
            error("Error looking up depended EJB or resource",ex);
        }
        catch (JMSException ex) {
            error("Error connecting to JMS queue",ex);
        }
    }
}