revert

Author: maxdml

dbos/queue.go

@@ -205,9 +205,13 @@ func (qr *queueRunner) listQueues() []WorkflowQueue {
 }
 
 // getQueue returns the queue with the given name from the registry.
-// Returns the queue if found, or an empty queue if it does not exist.
-func (qr *queueRunner) getQueue(queueName string) WorkflowQueue {
-	return qr.workflowQueueRegistry[queueName]
+// Returns a pointer to the queue if found, or nil if it does not exist.
+func (qr *queueRunner) getQueue(queueName string) *WorkflowQueue {
+	queue, exists := qr.workflowQueueRegistry[queueName]
+	if !exists {
+		return nil
+	}
+	return &queue
 }
 
 // run starts a goroutine for each registered queue to handle polling independently.