src/main/java/at/ac/tuwien/sbc/valesriegler/xvsm/GroupXVSM.java

   1 package at.ac.tuwien.sbc.valesriegler.xvsm;
   2
   3 import java.io.Serializable;
   4 import java.util.Arrays;
   5 import java.util.List;
   6 import java.util.Random;
   7
   8 import org.mozartspaces.core.MzsConstants.RequestTimeout;
   9 import org.mozartspaces.notifications.Notification;
  10 import org.mozartspaces.notifications.NotificationListener;
  11 import org.mozartspaces.notifications.Operation;
  12 import org.slf4j.Logger;
  13 import org.slf4j.LoggerFactory;
  14
  15 import at.ac.tuwien.sbc.valesriegler.common.Util;
  16 import at.ac.tuwien.sbc.valesriegler.types.GroupData;
  17 import at.ac.tuwien.sbc.valesriegler.types.Order;
  18
  19 public class GroupXVSM extends AbstractXVSMConnector {
  20         private static final Logger log = LoggerFactory.getLogger(GroupXVSM.class);
  21
  22         private int groupId;
  23
  24         private Random random = new Random();
  25
  26         public GroupXVSM(int groupId, int port) {
  27                 super(port);
  28                 this.groupId = groupId;
  29
  30                 paymentRequestContainer = useContainerOfSpaceWithPort(Util.PAYMENT_REQUEST, port) ;
  31                 orderCompleteContainer = useContainerOfSpaceWithPort(Util.ORDER_COMPLETE, port) ;
  32 //              isEatingContainer = useContainer(Util.IS_EATING) ;
  33 //              freeTablesContainer = useContainer(Util.FREE_TABLES) ;
  34         }
  35
  36         public void waitForMyOrder() {
  37                 log.info("Thread started for group {}", groupId);
  38                 NotificationListener deliveredOrders = new NotificationListener() {
  39             @Override
  40             public void entryOperationFinished(final Notification notification, final Operation operation, final List<? extends Serializable> entries) {
  41                 final List<GroupData> groups = castEntries(entries);
  42
  43                 final Order order = groups.get(0).getOrder();
  44
  45                                 if(order.getGroupId() == groupId) {
  46                                         eatAndThenPay();
  47                                 }
  48             }
  49         };
  50           try {
  51                 notificationMgr.createNotification(orderCompleteContainer, deliveredOrders, Operation.WRITE);
  52         } catch (Exception e) {
  53            handleSpaceErrorAndTerminate(e);
  54         }
  55         }
  56
  57         private void eatAndThenPay() {
  58                 int timeToEat = Util.getRandom(3, 5);
  59                 log.info("I eat {} seconds now...", timeToEat);
  60
  61                 GroupData groupData = new GroupData();
  62                 groupData.setId(groupId);
  63
  64                 try {
  65                         Thread.sleep(timeToEat * 1000);
  66                 } catch (InterruptedException e) {
  67                         e.printStackTrace();
  68                 }
  69
  70                 sendItemsToContainer(Arrays.asList(groupData), paymentRequestContainer, RequestTimeout.DEFAULT, null);
  71                 log.info("I sent my payment request to the space! GroupId: {}", groupId);
  72         }
  73
  74 }