Examples of addEvents()

Examples of org.activiti.crystalball.simulator.SimpleEventCalendar.addEvents()

217
218
219
220
221
222
223
224
225
226
227
          ExplorerApp.get().setCrystalBallSimulationEvents(simulationEvents);
         
          SimpleEventCalendar eventCalendar = new SimpleEventCalendar(
              ProcessEngines.getDefaultProcessEngine().getProcessEngineConfiguration().getClock(),
              new SimulationEventComparator());
          eventCalendar.addEvents(simulationEvents);
 
          // replay process instance run
          simulationDebugger = new ReplaySimulationRun(ProcessEngines.getDefaultProcessEngine(),
              eventCalendar, getReplayHandlers(processInstanceId));
          ExplorerApp.get().setCrystalBallSimulationDebugger(simulationDebugger);
View Full Code Here

Examples of org.apache.hadoop.yarn.api.records.timeline.TimelineEntity.addEvents()

226
227
228
229
230
231
232
233
234
235
236
      }
      if (entity.getEvents() != null) {
        if (existingEntity.getEvents() == null) {
          existingEntity.setEvents(entity.getEvents());
        } else {
          existingEntity.addEvents(entity.getEvents());
        }
        Collections.sort(existingEntity.getEvents());
      }
      // check startTime
      if (existingEntity.getStartTime() == null) {
View Full Code Here

Examples of org.apache.hadoop.yarn.api.records.timeline.TimelineEntity.addEvents()

313
314
315
316
317
318
319
320
321
322
323
    entityToReturn.setEntityId(entity.getEntityId());
    entityToReturn.setEntityType(entity.getEntityType());
    entityToReturn.setStartTime(entity.getStartTime());
    // Deep copy
    if (fields.contains(Field.EVENTS)) {
      entityToReturn.addEvents(entity.getEvents());
    } else if (fields.contains(Field.LAST_EVENT_ONLY)) {
      entityToReturn.addEvent(entity.getEvents().get(0));
    } else {
      entityToReturn.setEvents(null);
    }
View Full Code Here

Examples of org.apache.hadoop.yarn.api.records.timeline.TimelineEntity.addEvents()

227
228
229
230
231
232
233
234
235
236
237
      }
      if (entity.getEvents() != null) {
        if (existingEntity.getEvents() == null) {
          existingEntity.setEvents(entity.getEvents());
        } else {
          existingEntity.addEvents(entity.getEvents());
        }
        Collections.sort(existingEntity.getEvents());
      }
      // check startTime
      if (existingEntity.getStartTime() == null) {
View Full Code Here

Examples of org.cspoker.common.api.shared.http.HTTPResponse.addEvents()

71
72
73
74
75
76
77
78
79
80
81
    response.addActionResult(new ActionPerformedEvent<Void>(action1,null));
    response.addActionResult(new ActionPerformedEvent<Void>(action2,null));
   
    Queue<ServerEvent> equeue = new LinkedList<ServerEvent>();
    equeue.add(new HoldemTableTreeEventWrapper(tid, new BetEvent(new PlayerId(5),25)));
    response.addEvents(equeue);
   
    marschaller.marshal(response, output);

    output = new File(baseDir,"http.xml");
   
View Full Code Here

Examples of org.opencustomer.connector.mail.messages.StatusEmail.addEvents()

91
92
93
94
95
96
97
98
99
100
101
                                mail.addJobs(job);
                           
                            if(log.isDebugEnabled())
                                log.debug(events.size() + "events found");
                            for(EventVO event : events)
                                mail.addEvents(event);
                           
                            if(log.isDebugEnabled())
                                log.debug("sending status mail for: " + user.getUserName());
                            new MailService().send(mail);
                        } else {
View Full Code Here

Examples of org.red5.server.so.SharedObjectMessage.addEvents()

1351
1352
1353
1354
1355
1356
1357
1358
1359
1360
1361
   */
  public void sendSharedObjectMessage(String name, int currentVersion, boolean persistent, ConcurrentLinkedQueue<ISharedObjectEvent> events) {
    // create a new sync message for every client to avoid concurrent access through multiple threads
    SharedObjectMessage syncMessage = state.getEncoding() == Encoding.AMF3 ? new FlexSharedObjectMessage(null, name, currentVersion, persistent) : new SharedObjectMessage(
        null, name, currentVersion, persistent);
    syncMessage.addEvents(events);
    try {
      // get the channel for so updates
      Channel channel = getChannel((byte) 3);
      if (log.isTraceEnabled())
        log.trace("Send to channel: {}", channel);
View Full Code Here

Examples of rinde.sim.scenario.ScenarioBuilder.addEvents()

322
323
324
325
326
327
328
329
330
331
332
    sb.addEvent(new AddDepotEvent(-1, depotPosition));
    for (int i = 0; i < vehicles; i++) {
      sb.addEvent(new AddVehicleEvent(-1, new VehicleDTO(depotPosition,
          truckSpeed, 0, new TimeWindow(0, totalTime))));
    }
    sb.addEvents(parcels.get(online));
    sb.addEvent(new TimedEvent(TIME_OUT, totalTime));

    return sb.build(new ScenarioCreator<Gendreau06Scenario>() {
      @Override
      public Gendreau06Scenario create(List<TimedEvent> eventList,
View Full Code Here

Examples of rinde.sim.scenario.ScenarioBuilder.addEvents()

119
120
121
122
123
124
125
126
127
128
129
    final ScenarioBuilder sb = new ScenarioBuilder(PDPScenarioEvent.ADD_DEPOT,
        PDPScenarioEvent.ADD_PARCEL, PDPScenarioEvent.ADD_VEHICLE,
        PDPScenarioEvent.TIME_OUT);
    sb.addEvent(new AddDepotEvent(-1, depotLocation));
    sb.addEvents(vehicleGenerator.generate(rng));

    for (final long time : times) {
      final Point pickup = locations.get(index++);
      final Point delivery = locations.get(index++);
      final ImmutableList<TimeWindow> tws = timeWindowGenerator.generate(time,
View Full Code Here

Examples of rinde.sim.scenario.ScenarioBuilder.addEvents()

36
37
38
39
40
41
42
43
44
45
46
        .parser()
        .addFile(new ByteArrayInputStream("".getBytes()), "req_rapide_1_240_24")
        .setNumVehicles(numTrucks)
        .parse().get(0);
    final ScenarioBuilder sb = new ScenarioBuilder(gs.getPossibleEventTypes());
    sb.addEvents(gs.asList());
    sb.addEvents(parcels);
    return sb.build(new ScenarioCreator<Gendreau06Scenario>() {
      @Override
      public Gendreau06Scenario create(List<TimedEvent> eventList,
          Set<Enum<?>> eventTypes) {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.