Added option to enable MQ trace for crtmqm
This commit is contained in:
committed by
Luke J Powlett
parent
a778eb1cc9
commit
9252465cab
@@ -170,12 +170,29 @@ func doMain() error {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
enableTraceCrtmqm := os.Getenv("MQ_ENABLE_TRACE_CRTMQM")
|
||||||
|
if enableTraceCrtmqm == "true" || enableTraceCrtmqm == "1" {
|
||||||
|
err = startMQTrace()
|
||||||
|
if err != nil {
|
||||||
|
logTermination(err)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
newQM, err := createQueueManager(name, *devFlag)
|
newQM, err := createQueueManager(name, *devFlag)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
logTermination(err)
|
logTermination(err)
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if enableTraceCrtmqm == "true" || enableTraceCrtmqm == "1" {
|
||||||
|
err = endMQTrace()
|
||||||
|
if err != nil {
|
||||||
|
logTermination(err)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
var wg sync.WaitGroup
|
var wg sync.WaitGroup
|
||||||
defer func() {
|
defer func() {
|
||||||
log.Debug("Waiting for log mirroring to complete")
|
log.Debug("Waiting for log mirroring to complete")
|
||||||
|
|||||||
Reference in New Issue
Block a user