gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 11:48:43 -07:00
Code Issues Packages Projects Releases Wiki Activity

Fixed flapper

Browse Source 
Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
This commit is contained in:
Ivan Kozlovic
2020-06-18 16:13:17 -06:00
parent 9bf85aca2b
commit 53a990f426
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
test/leafnode_test.go
View File

@@ -1428,12 +1428,13 @@ func TestLeafNodeUserPermsForConnection(t *testing.T) {
checkNoSubInterest(t, s, acc.GetName(), "bar", 20*time.Millisecond)
// This one should.
nc2.SubscribeSync("foo.22")
checkSubInterest(t, s, acc.GetName(), "foo.22", 20*time.Millisecond)
checkSubInterest(t, s, acc.GetName(), "foo.22", 100*time.Millisecond)
// Capture everything.
sub, _ := nc.SubscribeSync(">")
nc.Flush()
checkSubInterest(t, sl, "$G", ">", 100*time.Millisecond)
// Now check local pubs are not forwarded.
nc2.Publish("baz.22", nil)
m, err := sub.NextMsg(1 * time.Second)