# | |
# Sleep 5s during streaming session | |
# | |
RULE sleep 10s 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(5000) | |
ENDRULE |