Merge pull request #131 from kobergj/AllowDisablingDurableStreams

Allow disabling durable streams
micro · Nov 30, 2023 · 185a524 · 185a524
2 parents d72facc + 48ccb79
commit 185a524
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 10 deletions.
diff --git a/v4/events/natsjs/nats.go b/v4/events/natsjs/nats.go
@@ -203,8 +203,10 @@ func (s *stream) Consume(topic string, opts ...events.ConsumeOption) (<-chan eve
 	}
 
 	// setup the options
-	subOpts := []nats.SubOpt{
-		nats.Durable(options.Group),
+	subOpts := []nats.SubOpt{}
+
+	if !s.opts.DisableDurableStreams {
+		subOpts = append(subOpts, nats.Durable(options.Group))
 	}
 
 	if options.CustomRetries {

diff --git a/v4/events/natsjs/options.go b/v4/events/natsjs/options.go
@@ -8,14 +8,15 @@ import (
 
 // Options which are used to configure the nats stream.
 type Options struct {
-	ClusterID   string
-	ClientID    string
-	Address     string
-	NkeyConfig  string
-	TLSConfig   *tls.Config
-	Logger      logger.Logger
-	SyncPublish bool
-	Name        string
+	ClusterID             string
+	ClientID              string
+	Address               string
+	NkeyConfig            string
+	TLSConfig             *tls.Config
+	Logger                logger.Logger
+	SyncPublish           bool
+	Name                  string
+	DisableDurableStreams bool
 }
 
 // Option is a function which configures options.
@@ -76,3 +77,10 @@ func Name(name string) Option {
 		o.Name = name
 	}
 }
+
+// DisableDurableStreams will disable durable streams
+func DisableDurableStreams() Option {
+	return func(o *Options) {
+		o.DisableDurableStreams = true
+	}
+}