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

Corrected spelling of 'propagated' and 'propagation'

Browse Source
This commit is contained in:
Larry McQueary
2016-02-02 12:22:49 -07:00
parent ed3c20f13e
commit 7b5baa97d1
3 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
test/client_cluster_test.go
View File

@@ -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

10
test/cluster_test.go
View File

@@ -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()

2
test/routes_test.go
View File

@@ -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()