equal
deleted
inserted
replaced
65 this.active = active; |
65 this.active = active; |
66 repositoryFiles = new RepositoryFiles(fileAccess, p); |
66 repositoryFiles = new RepositoryFiles(fileAccess, p); |
67 } |
67 } |
68 |
68 |
69 @Override |
69 @Override |
70 public void process() throws IOException { |
70 public void process() throws Exception { |
71 final StreamConfiguration c1 = configuration; |
71 final StreamConfiguration c1 = configuration; |
72 Path path; |
72 Path path; |
73 boolean validStartTime = active || c1.getStartTime() != null; |
73 boolean validStartTime = active || c1.getStartTime() != null; |
74 if (validStartTime) { |
74 if (validStartTime) { |
75 path = repositoryFiles.firstPath(c1.getStartNanos()); |
75 path = repositoryFiles.firstPath(c1.getStartNanos()); |
270 |
270 |
271 public void startAsync(long startNanos) { |
271 public void startAsync(long startNanos) { |
272 eventStream.startAsync(startNanos); |
272 eventStream.startAsync(startNanos); |
273 } |
273 } |
274 |
274 |
|
275 @Override |
|
276 public void onError(Consumer<Throwable> action) { |
|
277 // TODO Auto-generated method stub |
|
278 |
|
279 } |
|
280 |
275 |
281 |
276 } |
282 } |