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