When an execution times out and the worker channel restarts as a result (here), no exception is passed into the call to shut down the existing channel . This results in TryFailExecutions() exiting ...