fix: gracefully stop the queue (#25)

Author: bxcodec

.github/workflows/lint.yaml

@@ -13,7 +13,7 @@ jobs:
     runs-on: ubuntu-latest
     strategy:
       matrix:
-        go-version: ["oldstable", "stable"]
+        go-version: ["stable"]
     env:
       VERBOSE: 1
 

go.mod

@@ -1,6 +1,6 @@
 module github.com/bxcodec/goqueue
 
-go 1.22
+go 1.23
 
 require (
 	github.com/google/uuid v1.6.0

queueservice.go

@@ -65,17 +65,18 @@ func (qs *QueueService) Start(ctx context.Context) (err error) {
 // Stop stops the queue service by stopping the consumer and closing the publisher.
 // It returns an error if there was an issue stopping the consumer or closing the publisher.
 func (qs *QueueService) Stop(ctx context.Context) error {
-	if qs.consumer == nil {
-		return errors.New("consumer is not defined")
-	}
-	err := qs.consumer.Stop(ctx)
-	if err != nil {
-		return err
+	if qs.consumer != nil {
+		err := qs.consumer.Stop(ctx)
+		if err != nil {
+			return err
+		}
 	}
 
-	err = qs.publisher.Close(ctx)
-	if err != nil {
-		return err
+	if qs.publisher != nil {
+		err := qs.publisher.Close(ctx)
+		if err != nil {
+			return err
+		}
 	}
 	return nil
 }