From ac18465de845ef457f4fa8680e559e1c0c5be53e Mon Sep 17 00:00:00 2001 From: Peter Sanchez Date: Thu, 22 Sep 2022 18:54:50 -0600 Subject: [PATCH] Adding work queues method --- server/server.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/server/server.go b/server/server.go index 6c7445c..a1c3a73 100644 --- a/server/server.go +++ b/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 -- 2.45.2