Read the latest value of lastSink

Multiple threads could access the field, lastSink, then they should read
the latest value of lastSink

Change-Id: I279ed6fa3db357008603cde5cb2c57671e66b33c

@@ -69,7 +69,7 @@ public class CoreEventDispatcher extends DefaultEventSinkRegistry
 
 
     // Means to detect long-running sinks
     // Means to detect long-running sinks
     private TimerTask watchdog;
     private TimerTask watchdog;
-    private EventSink lastSink;
+    private volatile EventSink lastSink;
     private final AtomicLong lastStart = new AtomicLong(0);
     private final AtomicLong lastStart = new AtomicLong(0);
     private volatile Future<?> dispatchFuture;
     private volatile Future<?> dispatchFuture;
 
 
@@ -164,11 +164,12 @@ public class CoreEventDispatcher extends DefaultEventSinkRegistry
             long delta = System.currentTimeMillis() - lastStartLocal;
             long delta = System.currentTimeMillis() - lastStartLocal;
             if (lastStartLocal > 0 && delta > maxProcessMillis) {
             if (lastStartLocal > 0 && delta > maxProcessMillis) {
                 lastStart.set(0);
                 lastStart.set(0);
+                EventSink lastSinkLocal = lastSink;
                 log.warn("Event sink {} exceeded execution time limit: {} ms; spawning new dispatch loop",
                 log.warn("Event sink {} exceeded execution time limit: {} ms; spawning new dispatch loop",
-                          lastSink.getClass().getName(), delta);
+                          lastSinkLocal.getClass().getName(), delta);
 
 
                 // Notify the sink that it has exceeded its time limit.
                 // Notify the sink that it has exceeded its time limit.
-                lastSink.onProcessLimit();
+                lastSinkLocal.onProcessLimit();
 
 
                 // Cancel the old dispatch loop and submit a new one.
                 // Cancel the old dispatch loop and submit a new one.
                 dispatchLoop.stop();
                 dispatchLoop.stop();