Shutdown servers after test

mail2fish · Dec 19, 2014 · c44a25e · c44a25e
1 parent 48f6086
commit c44a25e
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/test/client_cluster_test.go b/test/client_cluster_test.go
@@ -233,7 +233,9 @@ func TestServerRestartAndQueueSubs(t *testing.T) {
 
 // This will test request semantics across a route
 func TestRequestsAcrossRoutes(t *testing.T) {
-	_, _, optsA, optsB := runServers(t)
+	srvA, srvB, optsA, optsB := runServers(t)
+	defer srvA.Shutdown()
+	defer srvB.Shutdown()
 
 	urlA := fmt.Sprintf("nats://%s:%d/", optsA.Host, optsA.Port)
 	urlB := fmt.Sprintf("nats://%s:%d/", optsB.Host, optsB.Port)
@@ -269,7 +271,9 @@ func TestRequestsAcrossRoutes(t *testing.T) {
 
 // This will test request semantics across a route to queues
 func TestRequestsAcrossRoutesToQueues(t *testing.T) {
-	_, _, optsA, optsB := runServers(t)
+	srvA, srvB, optsA, optsB := runServers(t)
+	defer srvA.Shutdown()
+	defer srvB.Shutdown()
 
 	urlA := fmt.Sprintf("nats://%s:%d/", optsA.Host, optsA.Port)
 	urlB := fmt.Sprintf("nats://%s:%d/", optsB.Host, optsB.Port)
@@ -313,5 +317,4 @@ func TestRequestsAcrossRoutesToQueues(t *testing.T) {
 			t.Fatalf("Received an error on Request test [%d]: %s", i, err)
 		}
 	}
-
 }