Package com.twitter.ambrose.model

Examples of com.twitter.ambrose.model.Event$JobStartedEvent


    for(Event event : testEvents) {
      service.pushEvent(workflowId, event);
    }

    int sinceId = -1;
    Event foundEvent;
    for(Event event : testEvents) {
      Iterator<Event> foundEvents = service.getEventsSinceId(workflowId, sinceId, 1).iterator();
      foundEvent = foundEvents.next();
      assertEqualWorkflows(event, foundEvent);
      assertFalse("Wrong number of events returned", foundEvents.hasNext());
      sinceId = foundEvent.getId();
    }
  }
View Full Code Here


      if (numElems >= maxEvents) {
        break;
      }
      String eventDataJson = flowEvent.getEventDataJSON();
      try {
        Event event = Event.fromJson(eventDataJson);
        numElems++;
        workflowEvents.add(event);
      } catch (JsonMappingException e) {
        LOG.error("Could not deserialize json: " + eventDataJson, e);
      }
View Full Code Here

TOP

Related Classes of com.twitter.ambrose.model.Event$JobStartedEvent

Copyright © 2018 www.massapicom. 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.