search

infinispan-demos / streaming-data-workshop

Streaming data workshop with Infinispan, Vert.x and OpenShift
11 stars 7 forks source link

Add delayed trains continuous query and dashboard #10

Closed galderz closed 6 years ago

galderz commented 6 years ago

@tsegismont Fixed all things

galderz commented 6 years ago

I'm going to integrate the PR now. @tsegismont we can continue that discussion about whether the event needs to be sent in context or not.

tsegismont commented 6 years ago

+1, it's easier for the attendee than to wonder what runOnContext is for.

2017-11-01 17:14 GMT+01:00 Galder Zamarreño notifications@github.com:

@galderz commented on this pull request.

In station-boards-injector/src/main/java/stream/ DelayedTrainsListenerVerticle.java https://github.com/infinispan-demos/streaming-data-workshop/pull/10#discussion_r148306405 :

  • client.stop();
  • }
  • private void addDelayedTrainsListener() {
  • stopsCache = client.getCache("default");
  • QueryFactory qf = Search.getQueryFactory(stopsCache);
  • Query query = qf.from(Stop.class)
  • .having("delayMin").gt(0L)
  • .build();
  • ContinuousQueryListener<String, Stop> listener =
  • new ContinuousQueryListener<String, Stop>() {
  • @Override
  • public void resultJoining(String id, Stop stop) {
  • vertx.runOnContext(x -> {

I had not forgotten about this. I've just fixed it https://github.com/infinispan-demos/streaming-data-workshop/commit/e36da2b308bf4497fcdb6fc62c5343489d40ed82 .

— You are receiving this because you were mentioned. Reply to this email directly, view it on GitHub https://github.com/infinispan-demos/streaming-data-workshop/pull/10#discussion_r148306405, or mute the thread https://github.com/notifications/unsubscribe-auth/ABbltrYq7KA3gbn0lJdyFRpl3zmKw4Wqks5syJkAgaJpZM4Plwbw .