if (args.length != 2)
throw new Exception("Usage: java JmsClient_ReservationProducer <CruiseID> <count>");
Integer cruiseID = new Integer(args[0]);
int count = new Integer(args[1]).intValue();
Context jndiContext = getInitialContext();
QueueConnectionFactory factory = (QueueConnectionFactory)jndiContext.lookup("java:comp/env/jms/QueueFactory");
Queue reservationQueue = (Queue)jndiContext.lookup("java:comp/env/jms/ReservationQueue");
Queue ticketQueue = (Queue)jndiContext.lookup("java:comp/env/jms/TicketQueue");
QueueConnection connect = factory.createQueueConnection();
QueueSession session = connect.createQueueSession(false,0);
QueueSender sender = session.createSender(reservationQueue);
for (int i = 0; i < count; i++) {
MapMessage message = session.createMapMessage();
message.setJMSReplyTo(ticketQueue); // Used in ReservationProcessor to send Tickets back out
message.setStringProperty("MessageFormat", "Version 3.4");
message.setInt("CruiseID", cruiseID.intValue());
message.setInt("CustomerID",i%2+1); // either Customer 1 or 2, all we've got in database
message.setInt("CabinID",i%10+100); // cabins 100-109 only
message.setDouble("Price", (double)1000+i);
// the card expires in about 30 days
Date expDate = new Date(System.currentTimeMillis()+43200000);
message.setString("CreditCardNum", "923830283029");
message.setLong("CreditCardExpDate", expDate.getTime());
message.setString("CreditCardType", CreditCardDO.MASTER_CARD);
System.out.println("Sending reservation message #"+i);
sender.send(message);
}
connect.close();
