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

   1 package at.ac.tuwien.sbc.valesriegler.xvsm;
   2
   3 import at.ac.tuwien.sbc.valesriegler.common.Util;
   4 import at.ac.tuwien.sbc.valesriegler.types.GroupData;
   5 import at.ac.tuwien.sbc.valesriegler.types.GroupState;
   6 import at.ac.tuwien.sbc.valesriegler.types.Order;
   7 import org.mozartspaces.core.MzsConstants.RequestTimeout;
   8 import org.mozartspaces.core.TransactionReference;
   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 java.io.Serializable;
  16 import java.util.Arrays;
  17 import java.util.List;
  18 import java.util.Random;
  19
  20 public class GroupXVSM extends AbstractXVSMConnector {
  21         private static final Logger log = LoggerFactory.getLogger(GroupXVSM.class);
  22
  23         private int groupId;
  24
  25         private Random random = new Random();
  26
  27         public GroupXVSM(int groupId, int port) {
  28                 super(port);
  29                 this.groupId = groupId;
  30
  31                 paymentRequestContainer = useContainerOfSpaceWithPort(Util.PAYMENT_REQUEST, port) ;
  32                 orderDeliveredContainer = useContainerOfSpaceWithPort(Util.ORDER_COMPLETE, port) ;
  33         pizzeriaGroupContainer = useContainerOfSpaceWithPort(Util.PIZZERIA_GROUP, port);
  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(orderDeliveredContainer, deliveredOrders, Operation.WRITE);
  52         } catch (Exception e) {
  53            Util.handleSpaceErrorAndTerminate(e);
  54         }
  55         }
  56
  57         private void eatAndThenPay() {
  58         try {
  59             int timeToEat = Util.getRandom(3, 5);
  60             log.info("I eat {} seconds now...", timeToEat);
  61
  62             try {
  63                 Thread.sleep(timeToEat * 1000);
  64             } catch (InterruptedException e) {
  65                 e.printStackTrace();
  66             }
  67
  68             GroupData groupData = new GroupData();
  69             groupData.setId(groupId);
  70             groupData.setState(GroupState.EATING);
  71             final TransactionReference tx = getDefaultTransaction();
  72
  73             final GroupData group = takeMatchingEntity(groupData, pizzeriaGroupContainer, tx, RequestTimeout.DEFAULT, "Group does not exist!");
  74
  75             group.setState(GroupState.PAY);
  76             final List<GroupData> groupList = Arrays.asList(group);
  77             sendItemsToContainer(groupList, paymentRequestContainer, RequestTimeout.DEFAULT, tx);
  78             sendItemsToContainer(groupList, pizzeriaGroupContainer, RequestTimeout.DEFAULT, tx);
  79             capi.commitTransaction(tx);
  80             log.info("I sent my payment request to the space! GroupId: {}", groupId);
  81
  82         } catch (Exception e) {
  83             log.error("hab mich verschluckt!");
  84         }
  85     }
  86
  87 }