src/main/java/at/ac/tuwien/sbc/valesriegler/DEBUG_CreateTable.java

   1 package at.ac.tuwien.sbc.valesriegler;
   2
   3 import javax.jms.Connection;
   4 import javax.jms.DeliveryMode;
   5 import javax.jms.MessageProducer;
   6 import javax.jms.Session;
   7
   8 import org.apache.activemq.ActiveMQConnectionFactory;
   9 import org.slf4j.Logger;
  10 import org.slf4j.LoggerFactory;
  11
  12 import at.ac.tuwien.sbc.valesriegler.types.PizzaType;
  13 import at.ac.tuwien.sbc.valesriegler.types.Table;
  14
  15 public class DEBUG_CreateTable {
  16         private static final Logger log = LoggerFactory.getLogger(DEBUG_CreateTable.class);
  17         private static int nextID = 0;
  18         final private int id;
  19
  20         public static void main(String[] args) throws Exception {
  21                 new DEBUG_CreateTable(++nextID);
  22         }
  23
  24         public DEBUG_CreateTable(int id) {
  25                 this.id = id;
  26                 log.info("I AM A DEBUG_CreateTable WITH ID {}", this.id);
  27                 produce(PizzaType.CARDINALE);
  28         }
  29
  30         public void produce(PizzaType pizzatype) {
  31                 try {
  32                         // Connecting to the Broker and to the output queue
  33                         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
  34                         Connection connection = connectionFactory.createConnection();
  35                         connection.start();
  36                         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  37
  38                         MessageProducer tableprod = session.createProducer(session.createQueue("TablesFree"));
  39                         tableprod.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
  40
  41                         // Create Tables
  42                         for (int i = 0; i < 2; i++) {
  43                                 tableprod.send(session.createObjectMessage(new Table(i)));
  44                         }
  45
  46                         // // Create Groups
  47                         // for (int i = 0; i < 1; i++) {
  48                         // Group g = new Group();
  49                         // g.setId(i);
  50                         // g.setSize(4);
  51                         // ArrayList<PizzaType> p = new ArrayList<PizzaType>();
  52                         // p.add(PizzaType.CARDINALE);
  53                         // p.add(PizzaType.MARGHERITA);
  54                         // p.add(PizzaType.SALAMI);
  55                         // p.add(PizzaType.MARGHERITA);
  56                         // Order o = new Order(p);
  57                         // g.setOrder(o);
  58                         // g.goGrabSomeFood(); // start the workflow.
  59                         // }
  60
  61                         // Clean up
  62                         session.close();
  63                         connection.close();
  64                 } catch (Exception e) {
  65                         log.error("Caught: ", e);
  66                         e.printStackTrace();
  67                 }
  68         }
  69 }