Compare commits
1
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
c294949f2a |
@@ -244,7 +244,7 @@ func (j *JetStream) EnsureConsumer(c Consumer) error {
|
|||||||
j.note("consumer %s on %s changes from %s to %s delivery on a stream that keeps its history: "+
|
j.note("consumer %s on %s changes from %s to %s delivery on a stream that keeps its history: "+
|
||||||
"re-made to deliver from now on, so nothing this one acknowledged comes back (novox/hq issue "+
|
"re-made to deliver from now on, so nothing this one acknowledged comes back (novox/hq issue "+
|
||||||
"207); %d ask(s) it had not acknowledged are not carried over and must be asked again",
|
"207); %d ask(s) it had not acknowledged are not carried over and must be asked again",
|
||||||
c.Name, c.Stream, shape(havePush), shape(wantPush), have.NumPending+have.NumAckPending)
|
c.Name, c.Stream, shape(havePush), shape(wantPush), have.NumPending+uint64(have.NumAckPending))
|
||||||
want.DeliverPolicy = nats.DeliverNewPolicy
|
want.DeliverPolicy = nats.DeliverNewPolicy
|
||||||
} else {
|
} else {
|
||||||
j.note("consumer %s on %s changes from %s to %s delivery: re-made where it left off, nothing "+
|
j.note("consumer %s on %s changes from %s to %s delivery: re-made where it left off, nothing "+
|
||||||
|
|||||||
Reference in New Issue
Block a user