academy/mq-container
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

endmqm -r try to reconnect (#268)

Browse Source
This commit is contained in:
LPowlett
2019-01-28 11:03:54 +00:00
committed by GitHub
parent d3eb6e0d3d
commit df6ce917c2
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
cmd/runmqserver/qmgr.go
View File

@@ -131,7 +131,7 @@ func configureQueueManager() error {
func stopQueueManager(name string) error { func stopQueueManager(name string) error {
log.Println("Stopping queue manager") log.Println("Stopping queue manager")
out, _, err := command.Run("endmqm", "-w", name) out, _, err := command.Run("endmqm", "-w", "-r", name)
if err != nil { if err != nil {
log.Printf("Error stopping queue manager: %v", string(out)) log.Printf("Error stopping queue manager: %v", string(out))
return err return err

4
test/docker/mqmetric_test.go
View File

@@ -1,5 +1,5 @@
/* /*
© Copyright IBM Corporation 2018 © Copyright IBM Corporation 2018, 2019
Licensed under the Apache License, Version 2.0 (the "License"); Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License. you may not use this file except in compliance with the License.
@@ -279,7 +279,7 @@ func TestQMRestart(t *testing.T) {
// Restart just the QM (to simulate a lost connection) // Restart just the QM (to simulate a lost connection)
t.Log("Stopping queue manager\n") t.Log("Stopping queue manager\n")
rc, out := execContainer(t, cli, id, "mqm", []string{"endmqm", "-w", defaultMetricQMName}) rc, out := execContainer(t, cli, id, "mqm", []string{"endmqm", "-w", "-r", defaultMetricQMName})
if rc != 0 { if rc != 0 {
t.Fatalf("Failed to stop the queue manager. rc=%d, err=%s", rc, out) t.Fatalf("Failed to stop the queue manager. rc=%d, err=%s", rc, out)
} }