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         groupAgentPaymentRequestContainer = useContainerOfSpaceWithPort(Util.GROUP_AGENT_PAYMENT_REQUEST, Util.GROUP_AGENT_PORT);
  32                 orderCompleteContainer = useContainerOfSpaceWithPort(Util.ORDER_COMPLETE, port) ;
  33 //              isEatingContainer = useContainer(Util.IS_EATING) ;
  34 //              freeTablesContainer = useContainer(Util.FREE_TABLES) ;
  35         }
  36
  37         public void waitForMyOrder() {
  38                 log.info("Thread started for group {}", groupId);
  39                 NotificationListener deliveredOrders = new NotificationListener() {
  40             @Override
  41             public void entryOperationFinished(final Notification notification, final Operation operation, final List<? extends Serializable> entries) {
  42                 final List<GroupData> groups = castEntries(entries);
  43
  44                 final Order order = groups.get(0).getOrder();
  45
  46                                 if(order.getGroupId() == groupId) {
  47                                         eatAndThenPay();
  48                                 }
  49             }
  50         };
  51           try {
  52                 notificationMgr.createNotification(orderCompleteContainer, deliveredOrders, Operation.WRITE);
  53         } catch (Exception e) {
  54            handleSpaceErrorAndTerminate(e);
  55         }
  56         }
  57
  58         private void eatAndThenPay() {
  59                 int timeToEat = Util.getRandom(3, 5);
  60                 log.info("I eat {} seconds now...", timeToEat);
  61
  62                 GroupData groupData = new GroupData();
  63                 groupData.setId(groupId);
  64
  65                 try {
  66                         Thread.sleep(timeToEat * 1000);
  67                 } catch (InterruptedException e) {
  68                         e.printStackTrace();
  69                 }
  70
  71                 sendItemsToContainer(Arrays.asList(groupData), paymentRequestContainer, RequestTimeout.DEFAULT, null);
  72         sendItemsToContainer(Arrays.asList(groupData), groupAgentPaymentRequestContainer, RequestTimeout.DEFAULT, null);
  73                 log.info("I sent my payment request to the space! GroupId: {}", groupId);
  74         }
  75
  76 }