Merge pull request #6 from JheSue/pullSubscribe

Pull subscribe
BrobridgeOrg · Feb 21, 2024 · 11e0f7a · 11e0f7a
2 parents 11aac41 + 391d12f
commit 11e0f7a
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/pkg/system/internal/product.go b/pkg/system/internal/product.go
@@ -257,14 +257,14 @@ func (pm *ProductManager) PrepareSubscription(productName string, durable string
 	// Preparing push consumer
 	subject := fmt.Sprintf(productEventSubject, pm.domain, productName, "*")
 	cfg := &nats.ConsumerConfig{
-		Durable:        durable,
-		Description:    "Product Subscription",
-		DeliverSubject: nats.NewInbox(),
-		FilterSubject:  subject,
-		AckPolicy:      nats.AckAllPolicy,
-		MaxAckPending:  2000,
-		MaxDeliver:     -1,
-		ReplayPolicy:   nats.ReplayInstantPolicy,
+		Durable:       durable,
+		Description:   "Product Subscription",
+		FilterSubject: subject,
+		AckPolicy:     nats.AckExplicitPolicy,
+		MaxAckPending: 2000,
+		MaxDeliver:    -1,
+		ReplayPolicy:  nats.ReplayInstantPolicy,
+		//DeliverSubject: nats.NewInbox(),
 	}
 
 	if startSeq > 0 {