#
# Sleep 60s during streaming session
#
RULE sleep 60s on stream session
CLASS org.apache.cassandra.streaming.StreamSession
METHOD messageReceived
AT ENTRY
# set flag to only run this rule once.
IF NOT flagged("done")
DO
   flag("done");
   Thread.sleep(60000)
ENDRULE