Synchronize state clearance when message received while stopped. Make `DefaultFlushPredicate` `static`.