| # | |
| # 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 |