package com.titan.clients;
import javax.jms.Message;
import javax.jms.MapMessage;
import javax.jms.Session;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueConnection;
import javax.jms.QueueSession;
import javax.jms.Queue;
import javax.jms.QueueSender;
import javax.jms.JMSException;
import javax.naming.Context;
import javax.naming.InitialContext;
import java.util.Properties;
import java.util.Date;
import com.titan.processpayment.*;
public class JmsClient_ReservationProducer {
public static void main(String [] args) throws Exception {
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("titan-QueueFactory");
Queue reservationQueue = (Queue)jndiContext.lookup("titan-ReservationQueue");
Queue ticketQueue = (Queue)jndiContext.lookup("titan-TicketQueue");
QueueConnection connect = factory.createQueueConnection();
QueueSession session = connect.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
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();
}
public static Context getInitialContext()
throws javax.naming.NamingException {
Properties p = new Properties();
p.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory");
p.put(Context.PROVIDER_URL, "t3://localhost:7001");
return new InitialContext(p);
}
}