You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
in go, on reconnect, a subscription with a limit is followed up by unsubscribe(max-received)
This can cause unnecessary traffic and unnecessarily dropped messages in queue subscribers.
This issue may be worse as, when the limit is actually hit no unsubscribe seems to occur.
These two methods call invalidate
NatsDispatcher.run() (io.nats.client.impl)
NatsSubscription.nextMessage(Duration) (io.nats.client.impl)
which does not seem to have unsubscribe in it's path. (sub.invalidate() does not either)
in go, on reconnect, a subscription with a limit is followed up by unsubscribe(max-received)
This can cause unnecessary traffic and unnecessarily dropped messages in queue subscribers.
nats.java/src/main/java/io/nats/client/impl/NatsDispatcher.java
Lines 163 to 170 in 7f7fe82
in Go:
https://github.com/nats-io/nats.go/blob/93a68d7e795f11c0aa30cfa38cf9a4702ae8d8b7/nats.go#L3591
This issue may be worse as, when the limit is actually hit no unsubscribe seems to occur.
These two methods call invalidate
NatsDispatcher.run() (io.nats.client.impl)
NatsSubscription.nextMessage(Duration) (io.nats.client.impl)
which does not seem to have unsubscribe in it's path. (sub.invalidate() does not either)
The text was updated successfully, but these errors were encountered: