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.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 ("ConnectionFactory");
      
      Queue reservationQueue = (Queue)jndiContext.lookup ("queue/titan-ReservationQueue");
      Queue ticketQueue = (Queue)jndiContext.lookup ("queue/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 () + 30*24*60*60*1000L);
         
         message.setString ("CreditCardNum", "5549861006051975");
         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
   {
      return new InitialContext ();
   }
}