Does this make sense? Or should there be some sort of "ensure connected" state, or maybe re-connect's should be injected?
Clearing the queue might also need to be the responsibility of the consumer of the API - as the queue will rapidly iterate through the queue knocking off connection failures
Does this make sense? Or should there be some sort of "ensure connected" state, or maybe re-connect's should be injected?
Clearing the queue might also need to be the responsibility of the consumer of the API - as the queue will rapidly iterate through the queue knocking off connection failures