* Add watcher to subscribe/ignore tubes on the fly
* Add timed out reservation to allow watcher to run when there are no jobs
* Add lost connection recovery