mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-02 03:38:42 -07:00
subs could be random
This commit is contained in:
@@ -239,8 +239,9 @@ func TestRouteOnlySendOnce(t *testing.T) {
|
||||
clientSend("PING\r\n")
|
||||
clientExpect(pongRe)
|
||||
|
||||
matches := expectMsgs(1)
|
||||
checkMsg(t, matches[0], "foo", "RSID:2:1", "", "2", "ok")
|
||||
expectMsgs(1)
|
||||
routeSend("PING\r\n")
|
||||
routeExpect(pongRe)
|
||||
}
|
||||
|
||||
func TestRouteQueueSemantics(t *testing.T) {
|
||||
|
||||
Reference in New Issue
Block a user