implement impl_in_flight API for MQ, replacing evacuation