@Override public void delayActivity(long time) { calls.add("delayActivity"); ActivityExecutionContextProvider provider = new ActivityExecutionContextProviderImpl(); ActivityExecutionContext context = provider.getActivityExecutionContext(); try { while (true) { Thread.sleep(time * 1000); context.recordActivityHeartbeat(null); } } catch (InterruptedException e) { } }
public CronExampleActivitiesImpl() { this(new ActivityExecutionContextProviderImpl()); }
public PeriodicWorkflowActivitiesImpl() { this.contextProvider = new ActivityExecutionContextProviderImpl(); }
public ErrorReportingActivitiesImpl() { this.contextProvider = new ActivityExecutionContextProviderImpl(); }