Merge pull request #126 from quexer/delivery_mode

feat: add rabbitmq.PublishDeliveryMode, a client.PublishOption for setting message delivery mode
micro · Nov 24, 2023 · 4c504d4 · 4c504d4
2 parents b60b46c + 09bc84c
commit 4c504d4
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/v4/broker/rabbitmq/options.go b/v4/broker/rabbitmq/options.go
@@ -5,6 +5,7 @@ import (
 	"time"
 
 	"go-micro.dev/v4/broker"
+	"go-micro.dev/v4/client"
 )
 
 type durableQueueKey struct{}
@@ -164,3 +165,14 @@ type ackSuccessKey struct{}
 func AckOnSuccess() broker.SubscribeOption {
 	return setSubscribeOption(ackSuccessKey{}, true)
 }
+
+// PublishDeliveryMode client.PublishOption for setting message "delivery mode"
+// mode , Transient (0 or 1) or Persistent (2)
+func PublishDeliveryMode(mode uint8) client.PublishOption {
+	return func(o *client.PublishOptions) {
+		if o.Context == nil {
+			o.Context = context.Background()
+		}
+		o.Context = context.WithValue(o.Context, deliveryMode{}, mode)
+	}
+}