Merge pull request #125 from quexer/export_ack_on_success

feat: export AckOnSuccess as server.SubscriberOption
micro · Nov 24, 2023 · 54179a1 · 54179a1
2 parents 4c504d4 + 055895c
commit 54179a1
Showing 1 changed file with 6 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/server"
 	"go-micro.dev/v4/client"
 )
 
@@ -33,6 +34,11 @@ type appID struct{}
 type externalAuth struct{}
 type durableExchange struct{}
 
+// ServerAckOnSuccess export AckOnSuccess server.SubscriberOption
+func ServerAckOnSuccess() server.SubscriberOption {
+	return setServerSubscriberOption(ackSuccessKey{}, true)
+}
+
 // DurableQueue creates a durable queue when subscribing.
 func DurableQueue() broker.SubscribeOption {
 	return setSubscribeOption(durableQueueKey{}, true)