@Override
        public Map<String, Object> snapshot() {
            Map<String, Object> state = new HashMap<>();
            state.put("ToNotifyQueue", toNotifyQueue);
            return state;
        }
When an object implementing interface <code>Runnable</code> is used
to create a thread, starting the thread causes the object's
<code>run</code> method to be called in that separately executing
thread.
<p>
The general contract of the method <code>run</code> is that it may
take any action whatsoever.

@see Thread#run()
modules/siddhi-core/src/main/java/io/siddhi/core/util/Scheduler.java