TravelAgentBeanpublic class TravelAgentBean extends Object implements javax.ejb.SessionBean
| Fields Summary |
|---|
| public CustomerRemote | customer | | public CruiseLocal | cruise | | public CabinLocal | cabin | | public javax.ejb.SessionContext | ejbContext | | public Context | jndiContext |
| Methods Summary |
|---|
| public TicketDO | bookPassage(CreditCardDO card, double price)
TopicConnection connect = null;
if (customer == null || cruise == null || cabin == null)
{
throw new IncompleteConversationalState();
}
try {
System.out.println("Obtaining reference to Reservation EJB");
ReservationHomeLocal reshome =
(ReservationHomeLocal)jndiContext.lookup("java:comp/env/ejb/ReservationHomeLocal");
ReservationLocal reservation =
reshome.create(customer, cruise, cabin, price,new java.sql.Date(System.currentTimeMillis()));
System.out.println("Obtaining reference to ProcessPayment EJB");
Object ref = jndiContext.lookup("ProcessPaymentHomeRemote");
ProcessPaymentHomeRemote ppHome = (ProcessPaymentHomeRemote)
PortableRemoteObject.narrow(ref, ProcessPaymentHomeRemote.class);
ProcessPaymentRemote process = ppHome.create();
process.byCredit(customer, card, price);
System.out.println("Successfully processed the byCredit method.");
process.remove();
System.out.println("Successfully removed the Process EJB");
TicketDO ticket = new TicketDO(customer,cruise,cabin,price);
String ticketDescription = ticket.toString();
System.out.println("Obtaining reference to jms topic factory EJB");
TopicConnectionFactory factory = (TopicConnectionFactory)
jndiContext.lookup("java:comp/env/jms/TopicFactory");
System.out.println("Obtaining reference to jms TicketTopic ");
Topic topic = (Topic)
jndiContext.lookup("java:comp/env/jms/TicketTopic");
connect = factory.createTopicConnection();
TopicSession session = connect.createTopicSession(false,Session.AUTO_ACKNOWLEDGE);
TopicPublisher publisher = session.createPublisher(topic);
TextMessage textMsg = session.createTextMessage();
textMsg.setText(ticketDescription);
System.out.println("Sending text message to jms/TicketTopic..");
publisher.publish(textMsg);
return ticket;
} catch (Exception e) {
throw new EJBException(e);
}
finally {
if (connect != null) {
try {
connect.close();
} catch (JMSException e) {}
}
}
| | public java.util.Collection | buildSampleData()
Collection results = new ArrayList();
try {
System.out.println("TravelAgentBean::buildSampleData()");
Object obj = jndiContext.lookup("java:comp/env/ejb/CustomerHomeRemote");
CustomerHomeRemote custhome = (CustomerHomeRemote)
javax.rmi.PortableRemoteObject.narrow(obj, CustomerHomeRemote.class);
CabinHomeLocal cabinhome =
(CabinHomeLocal)jndiContext.lookup("java:comp/env/ejb/CabinHomeLocal");
ShipHomeLocal shiphome =
(ShipHomeLocal)jndiContext.lookup("java:comp/env/ejb/ShipHomeLocal");
CruiseHomeLocal cruisehome =
(CruiseHomeLocal)jndiContext.lookup("java:comp/env/ejb/CruiseHomeLocal");
ReservationHomeLocal reshome =
(ReservationHomeLocal)jndiContext.lookup("java:comp/env/ejb/ReservationHomeLocal");
System.out.println("Creating Customers 1 and 2..");
CustomerRemote customer1 = custhome.create(new Integer(1));
customer1.setName( new Name("Smith","Bob") );
CustomerRemote customer2 = custhome.create(new Integer(2));
customer2.setName( new Name("Stalin","Joseph") );
results.add("Created customers with IDs 1 and 2..");
System.out.println("Creating Ships A and B..");
ShipLocal shipA = shiphome.create(new Integer(101), "Nordic Prince", 50000.0);
ShipLocal shipB = shiphome.create(new Integer(102), "Bohemian Rhapsody", 70000.0);
results.add("Created ships with IDs 101 and 102..");
System.out.println("Creating Cabins on the Ships");
ArrayList cabinsA = new ArrayList();
ArrayList cabinsB = new ArrayList();
for (int jj=0; jj<10; jj++) {
CabinLocal cabinA = cabinhome.create(new Integer(100+jj),shipA,"Suite 10"+jj,1,1);
cabinsA.add(cabinA);
CabinLocal cabinB = cabinhome.create(new Integer(200+jj),shipB,"Suite 20"+jj,2,1);
cabinsB.add(cabinB);
}
results.add("Created cabins on Ship A with IDs 100-109");
results.add("Created cabins on Ship B with IDs 200-209");
System.out.println("Creating three cruises for each ship");
CruiseLocal cruiseA1 = cruisehome.create("Alaska Cruise", shipA);
CruiseLocal cruiseA2 = cruisehome.create("Norwegian Fjords", shipA);
CruiseLocal cruiseA3 = cruisehome.create("Bermuda or Bust", shipA);
results.add("Created cruises on ShipA with IDs "+cruiseA1.getId()+", "+cruiseA2.getId()+", "+cruiseA3.getId());
CruiseLocal cruiseB1 = cruisehome.create("Indian Sea Cruise", shipB);
CruiseLocal cruiseB2 = cruisehome.create("Australian Highlights", shipB);
CruiseLocal cruiseB3 = cruisehome.create("Three-Hour Cruise", shipB);
results.add("Created cruises on ShipB with IDs "+cruiseB1.getId()+", "+cruiseB2.getId()+", "+cruiseB3.getId());
System.out.println("Making a few reservations...");
ReservationLocal res =
reshome.create(customer1, cruiseA1, (CabinLocal)(cabinsA.get(3)), 1000.0, new java.sql.Date(System.currentTimeMillis()));
res = reshome.create(customer1, cruiseB3, (CabinLocal)(cabinsB.get(8)), 2000.0, new java.sql.Date(System.currentTimeMillis()));
res = reshome.create(customer2, cruiseA2, (CabinLocal)(cabinsA.get(5)), 2000.0, new java.sql.Date(System.currentTimeMillis()));
res = reshome.create(customer2, cruiseB3, (CabinLocal)(cabinsB.get(2)), 2000.0, new java.sql.Date(System.currentTimeMillis()));
results.add("Made reservation for Customer 1 on Cruise "+cruiseA1.getId()+" for Cabin 103");
results.add("Made reservation for Customer 1 on Cruise "+cruiseB3.getId()+" for Cabin 208");
results.add("Made reservation for Customer 2 on Cruise "+cruiseA2.getId()+" for Cabin 105");
results.add("Made reservation for Customer 2 on Cruise "+cruiseB3.getId()+" for Cabin 202");
System.out.println("Created Reservations");
} catch (Exception e) {
e.printStackTrace();
throw new EJBException(e);
}
return results;
| | public void | ejbActivate()
| | public void | ejbCreate(CustomerRemote cust)
System.out.println("TravelAgentBean::ejbCreate");
customer = cust;
| | public void | ejbPassivate()
| | public void | ejbRemove()
| | private java.sql.Connection | getConnection()
try {
DataSource ds =
(DataSource)jndiContext.lookup("java:comp/env/jdbc/Titan");
return ds.getConnection();
} catch(NamingException ne) { throw new EJBException(ne); }
| | public java.lang.String[] | listAvailableCabins(int bedCount)
if (cruise == null)
throw new IncompleteConversationalState();
Connection con = null;
PreparedStatement ps = null;;
ResultSet result = null;
try {
Integer cruiseID = (Integer)cruise.getPrimaryKey();
Integer shipID = (Integer)cruise.getShip().getPrimaryKey();
con = getConnection();
ps = con.prepareStatement(
"select \"cabin\".\"id\", \"cabin\".\"name\", \"cabin\".\"deckLevel\" from \"CabinBeanTable\" \"cabin\" , \"ShipBean_cabins_CabinBean_shipTable\" \"ship_cabin\" "+
"where \"ship_cabin\".\"_ShipBean_id\" = ? and \"cabin\".\"bedCount\" = ? and \"ship_cabin\".\"_CabinBean_id\" = \"cabin\".\"id\" and \"cabin\".\"id\" NOT IN " +
"(SELECT \"RCL\".\"_CabinBean_id\" FROM \"ReservationBean_cabins_CabinBean_Table\" AS \"RCL\" , \"ReservationBeanTable\" AS \"R\", \"CruiseBean_reservations_ReservationBean_cruiseTable\" AS \"CR\" " +
" WHERE \"RCL\".\"_ReservationBean_id\" = \"R\".\"id\" AND \"R\".\"id\" = \"CR\".\"_ReservationBean_id\" AND \"CR\".\"_CruiseBean_id\" = ?)");
ps.setInt(1,shipID.intValue());
ps.setInt(2,bedCount);
ps.setInt(3,cruiseID.intValue());
result = ps.executeQuery();
Vector vect = new Vector();
while(result.next()) {
StringBuffer buf = new StringBuffer();
buf.append(result.getString(1));
buf.append(',");
buf.append(result.getString(2));
buf.append(',");
buf.append(result.getString(3));
vect.addElement(buf.toString());
}
String [] returnArray = new String[vect.size()];
vect.copyInto(returnArray);
return returnArray;
}
catch (Exception e) {
throw new EJBException(e);
}
finally {
try {
if (result != null) result.close();
if (ps != null) ps.close();
if (con!= null) con.close();
} catch(SQLException se) {
se.printStackTrace();
}
}
| | public void | setCabinID(java.lang.Integer cabinID)
try {
CabinHomeLocal home = (CabinHomeLocal)
jndiContext.lookup("java:comp/env/ejb/CabinHomeLocal");
cabin = home.findByPrimaryKey(cabinID);
} catch (NamingException ne) {
throw new EJBException(ne);
}
| | public void | setCruiseID(java.lang.Integer cruiseID)
try {
CruiseHomeLocal home = (CruiseHomeLocal)
jndiContext.lookup("java:comp/env/ejb/CruiseHomeLocal");
cruise = home.findByPrimaryKey(cruiseID);
} catch (NamingException ne) {
throw new EJBException(ne);
}
| | public void | setSessionContext(javax.ejb.SessionContext cntx)
ejbContext = cntx;
try {
jndiContext = new javax.naming.InitialContext();
} catch(NamingException ne) {
throw new EJBException(ne);
}
|
|
