1 package at.ac.tuwien.sbc.valesriegler.xvsm;
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 at.ac.tuwien.sbc.valesriegler.xvsm.spacehelpers.SpaceAction;
8 import org.mozartspaces.core.MzsConstants.RequestTimeout;
9 import org.mozartspaces.core.TransactionReference;
10 import org.slf4j.Logger;
11 import org.slf4j.LoggerFactory;
13 import java.io.Serializable;
14 import java.util.Arrays;
15 import java.util.List;
17 public class GroupXVSM extends AbstractXVSMConnector {
18 private static final Logger log = LoggerFactory.getLogger(GroupXVSM.class);
22 public GroupXVSM(int groupId, int port) {
24 this.groupId = groupId;
26 paymentRequestContainer = useContainerOfSpaceWithPort(Util.PAYMENT_REQUEST, port) ;
27 orderDeliveredContainer = useContainerOfSpaceWithPort(Util.ORDER_COMPLETE, port) ;
28 pizzeriaGroupContainer = useContainerOfSpaceWithPort(Util.PIZZERIA_GROUP, port);
31 public void waitForMyOrder() {
32 getDefaultBuilder().setCref(orderDeliveredContainer).setSpaceAction(new SpaceAction() {
34 public void onEntriesWritten(List<? extends Serializable> entries) throws Exception {
35 final List<GroupData> groups = castEntries(entries);
37 final Order order = groups.get(0).getOrder();
39 if(order.getGroupId() == groupId) {
42 }}).createSpaceListenerImpl();
45 private void eatAndThenPay() {
47 int timeToEat = Util.getRandom(3, 5);
48 log.info("I eat {} seconds now...", timeToEat);
51 Thread.sleep(timeToEat * 1000);
52 } catch (InterruptedException e) {
56 GroupData groupData = new GroupData();
57 groupData.setId(groupId);
58 groupData.setState(GroupState.EATING);
59 final TransactionReference tx = getDefaultTransaction();
61 final GroupData group = takeMatchingEntity(groupData, pizzeriaGroupContainer, tx, RequestTimeout.DEFAULT, "Group does not exist!");
63 group.setState(GroupState.PAY);
64 final List<GroupData> groupList = Arrays.asList(group);
65 sendItemsToContainer(groupList, paymentRequestContainer, RequestTimeout.DEFAULT, tx);
66 sendItemsToContainer(groupList, pizzeriaGroupContainer, RequestTimeout.DEFAULT, tx);
67 capi.commitTransaction(tx);
68 log.info("I sent my payment request to the space! GroupId: {}", groupId);
70 notificationMgr.shutdown();
72 } catch (Exception e) {
73 log.error("hab mich verschluckt!");