diff --git a/js.go b/js.go index a99c89d66..7785e4981 100644 --- a/js.go +++ b/js.go @@ -1408,6 +1408,10 @@ func (js *js) subscribe(subj, queue string, cb MsgHandler, ch chan *Msg, isSync, o.cfg.AckPolicy = AckNonePolicy o.cfg.MaxDeliver = 1 o.cfg.AckWait = 22 * time.Hour // Just set to something known, not utilized. + // Force R1 and MemoryStorage for these. + o.cfg.Replicas = 1 + o.cfg.MemoryStorage = true + if !hasHeartbeats { o.cfg.Heartbeat = orderedHeartbeatsInterval }