only include serializable headers in RabbitMQMessageScheme
detect closed connections during acking/failing in addition to getting next tuple