diff --git a/v4/broker/rabbitmq/options.go b/v4/broker/rabbitmq/options.go index 790076b8..aad0121a 100644 --- 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)