1 files changed, 5 insertions(+), 0 deletions(-)

M server/server.go

@@ 341,6 341,11 @@ func (s *Server) QueueTask(qname string, task *work.Task) error {
 	return fmt.Errorf("No queue found with name '%s'", qname)
 }
 
+// WorkQueues returns the `queues` slice
+func (s *Server) WorkQueues() []*work.Queue {
+	return s.queues
+}
+
 // WithEmail sets the email ServiceQueue instance
 func (s *Server) WithEmail(svc *email.ServiceQueue) *Server {
 	s.Email = svc