diff --git a/test/client_cluster_test.go b/test/client_cluster_test.go index f477e6fd..6644164a 100644 --- a/test/client_cluster_test.go +++ b/test/client_cluster_test.go @@ -147,7 +147,7 @@ func TestServerRestartAndQueueSubs(t *testing.T) { // Wait for processing. c1.Flush() c2.Flush() - // Wait for a short bit for cluster propogation. + // Wait for a short bit for cluster propagation. time.Sleep(50 * time.Millisecond) } @@ -263,7 +263,7 @@ func TestRequestsAcrossRoutes(t *testing.T) { nc1.Subscribe("foo-req", func(m *nats.Msg) { nc1.Publish(m.Reply, response) }) - // Make sure the route and the subscription are propogated. + // Make sure the route and the subscription are propagated. nc1.Flush() var resp string @@ -305,7 +305,7 @@ func TestRequestsAcrossRoutesToQueues(t *testing.T) { nc1.QueueSubscribe("foo-req", "booboo", func(m *nats.Msg) { nc1.Publish(m.Reply, response) }) - // Make sure the route and the subscription are propogated. + // Make sure the route and the subscription are propagated. nc1.Flush() // Connect the other responder to srvB diff --git a/test/cluster_test.go b/test/cluster_test.go index 12161e87..d0108be7 100644 --- a/test/cluster_test.go +++ b/test/cluster_test.go @@ -283,7 +283,7 @@ func TestClusterDropsRemoteSids(t *testing.T) { sendA("PING\r\n") expectA(pongRe) - // Wait for propogation. + // Wait for propagation. time.Sleep(100 * time.Millisecond) if sc := srvA.NumSubscriptions(); sc != 1 { @@ -298,7 +298,7 @@ func TestClusterDropsRemoteSids(t *testing.T) { sendA("PING\r\n") expectA(pongRe) - // Wait for propogation. + // Wait for propagation. time.Sleep(100 * time.Millisecond) if sc := srvA.NumSubscriptions(); sc != 2 { @@ -313,7 +313,7 @@ func TestClusterDropsRemoteSids(t *testing.T) { sendA("PING\r\n") expectA(pongRe) - // Wait for propogation. + // Wait for propagation. time.Sleep(100 * time.Millisecond) if sc := srvA.NumSubscriptions(); sc != 1 { @@ -326,7 +326,7 @@ func TestClusterDropsRemoteSids(t *testing.T) { // Close the client and make sure we remove subscription state. clientA.Close() - // Wait for propogation. + // Wait for propagation. time.Sleep(100 * time.Millisecond) if sc := srvA.NumSubscriptions(); sc != 0 { t.Fatalf("Expected no subscriptions for srvA, got %d\n", sc) @@ -337,7 +337,7 @@ func TestClusterDropsRemoteSids(t *testing.T) { } // This will test that we drop remote sids correctly. -func TestAutoUnsubscribePropogation(t *testing.T) { +func TestAutoUnsubscribePropagation(t *testing.T) { srvA, srvB, optsA, _ := runServers(t) defer srvA.Shutdown() defer srvB.Shutdown() diff --git a/test/routes_test.go b/test/routes_test.go index 61759d45..e75a95bc 100644 --- a/test/routes_test.go +++ b/test/routes_test.go @@ -463,7 +463,7 @@ func TestRouteResendsLocalSubsOnReconnect(t *testing.T) { routeExpect(subRe) } -func TestAutoUnsubPropogation(t *testing.T) { +func TestAutoUnsubPropagation(t *testing.T) { s, opts := runRouteServer(t) defer s.Shutdown()