From 27a0bb627dbf98f132c6fa005a606022a195b7ec Mon Sep 17 00:00:00 2001
From: Nam Huynh <namhq.1989@gmail.com>
Date: Thu, 14 Oct 2021 09:07:22 +0700
Subject: [PATCH] add more config to stream

---
 stream.go | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/stream.go b/stream.go
index 8a3b2fb..e5ee1df 100644
--- a/stream.go
+++ b/stream.go
@@ -23,8 +23,13 @@ func AddStream(name string, subjects []string) error {
 	if stream == nil {
 		subjectNames := generateSubjectNames(name, subjects)
 		_, err := natsJS.AddStream(&nats.StreamConfig{
-			Name:     name,
-			Subjects: subjectNames,
+			Name:         name,
+			Subjects:     subjectNames,
+			Retention:    nats.WorkQueuePolicy,
+			MaxConsumers: -1,
+			MaxMsgSize:   -1,
+			MaxMsgs:      -1,
+			NoAck:        false,
 		})
 		if err != nil {
 			msg := fmt.Sprintf("add stream error: %s", err.Error())