Fix test with new ackFunc stuff

eclipse · Oct 30, 2018 · 9190d1f · 9190d1f
1 parent 9bcc1fb
commit 9190d1f
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/unit_router_test.go b/unit_router_test.go
@@ -269,8 +269,7 @@ func Test_MatchAndDispatch(t *testing.T) {
 	router, stopper := newRouter()
 	router.addRoute("a", cb)
 
-	router.matchAndDispatch(msgs, true, nil)
-
+	router.matchAndDispatch(msgs, true, &client{oboundP: make(chan *PacketAndToken, 100)})
 	msgs <- pub
 
 	<-calledback
@@ -302,7 +301,7 @@ func Test_SharedSubscription_MatchAndDispatch(t *testing.T) {
 	router, stopper := newRouter()
 	router.addRoute("$share/az1/a", cb)
 
-	router.matchAndDispatch(msgs, true, nil)
+	router.matchAndDispatch(msgs, true, &client{oboundP: make(chan *PacketAndToken, 100)})
 
 	msgs <- pub