Merge pull request #124 from quexer/main

feat: add ServerDurableQueue, providing durable queue option for micro.RegisterSubscriber
micro · Nov 24, 2023 · 6c2dd05 · 6c2dd05
2 parents 54179a1 + 44f89a7
commit 6c2dd05
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/v4/broker/rabbitmq/options.go b/v4/broker/rabbitmq/options.go
@@ -7,6 +7,7 @@ import (
 	"go-micro.dev/v4/broker"
 	"go-micro.dev/v4/server"
 	"go-micro.dev/v4/client"
+	"go-micro.dev/v4/server"
 )
 
 type durableQueueKey struct{}
@@ -34,6 +35,11 @@ type appID struct{}
 type externalAuth struct{}
 type durableExchange struct{}
 
+// ServerDurableQueue provide durable queue option for micro.RegisterSubscriber
+func ServerDurableQueue() server.SubscriberOption {
+	return setServerSubscriberOption(durableQueueKey{}, true)
+}
+
 // ServerAckOnSuccess export AckOnSuccess server.SubscriberOption
 func ServerAckOnSuccess() server.SubscriberOption {
 	return setServerSubscriberOption(ackSuccessKey{}, true)