search

infinispan-demos / streaming-data-workshop

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

Fix data loading issues #45

Closed tsegismont closed 6 years ago

tsegismont commented 6 years ago

One process was still using doOnNext, so ignoring the completion of the operation.

Also, previous implementations of StationsInjector and PositionsInjector were often interrupted by a RejectedOperationException. This was due to the queue of the ISPN client asyncExecutor being full. The new implementation makes sure no more than 100 puts can be scheduled at once.

galderz commented 6 years ago

Looks good.

galderz commented 6 years ago

I'll retest later and then push if it looks good.

galderz commented 6 years ago

Just verified, this is an important fix actually. Without it, not enough train positions were being injected. Thanks @tsegismont