diff --git a/resque-sharp/Resque.cs b/resque-sharp/Resque.cs index 34e6db3..d77add1 100644 --- a/resque-sharp/Resque.cs +++ b/resque-sharp/Resque.cs @@ -34,6 +34,11 @@ public static Worker[] working() return Worker.working(); } + public static Worker[] workers() + { + return Worker.all(); + } + public static bool Push(string queue, object item) { watchQueue(queue); diff --git a/tests/WorkerTest.cs b/tests/WorkerTest.cs index 90794e6..2dce873 100644 --- a/tests/WorkerTest.cs +++ b/tests/WorkerTest.cs @@ -48,5 +48,15 @@ public void KnowsWhoIsWorking() }); } + [Test] + public void InsertsItselfIntoTheWorkersListOnStartup() + { + worker.work(0, + (Job job) => + { + Assert.That(Resque.workers()[0].workerId(), Is.EqualTo(worker.workerId())); return true; + }); + } + } }