Fix release/reject

rabbitmq · Sep 2, 2024 · c92253f · c92253f
1 parent b202cae
commit c92253f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/amqp10_client/consumer.go b/pkg/amqp10_client/consumer.go
@@ -174,9 +174,9 @@ func (c *Amqp10Consumer) Start(ctx context.Context, subscribed chan bool) {
 			case "accept":
 				err = c.Receiver.AcceptMessage(ctx, msg)
 			case "release":
-				err = c.Receiver.RejectMessage(ctx, msg, nil)
-			case "reject":
 				err = c.Receiver.ReleaseMessage(ctx, msg)
+			case "reject":
+				err = c.Receiver.RejectMessage(ctx, msg, nil)
 			}
 			if err != nil {
 				if err == context.Canceled {