-
Notifications
You must be signed in to change notification settings - Fork 154
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Ordered Consumer Heartbeat Handling #712
Conversation
js.PushSubscribeAsync(null, (o, a) => { }, false, psoBind).Unsubscribe(); | ||
UnsubscribeEnsureNotBound(js.PushSubscribeSync(null, psoBind)); | ||
UnsubscribeEnsureNotBound(js.PushSubscribeSync("", psoBind)); | ||
UnsubscribeEnsureNotBound(js.PushSubscribeAsync(null, (o, a) => { }, false, psoBind)); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Helps test on slow machines.
@@ -305,7 +305,7 @@ public void TestSourceBasics() | |||
|
|||
private void AssertMirror(IJetStreamManagement jsm, | |||
string stream, string mirroring, ulong? msgCount, ulong? firstSeq) { | |||
Thread.Sleep(1000); | |||
Thread.Sleep(1500); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
more time for slow machines
|
||
internal static PushMessageManagerFactory PushMessageManagerFactoryImpl = | ||
(conn, so, cc, queueMode, syncMode) => new PushMessageManager(conn, so, cc, queueMode, syncMode); | ||
internal static PushMessageManagerFactory PushMessageManagerFactoryImpl; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This allows a factory to be set for testing. The default one is used later if this one is not set. Change makes sense in the context of sub classing versus multiple managers
using System.Collections.Generic; | ||
using System.Threading; | ||
using NATS.Client.Internals; | ||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Split this file with multiple related classes into separate files matching the class name.
#700