Skip to content

Commit 71a2e85

Browse files
committed
comments
1 parent a842551 commit 71a2e85

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

mqmetric/mqif.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -698,6 +698,7 @@ func clearDurableSubscriptions(prefix string, cmdQObj ibmmq.MQObject, replyQObj
698698
clearQ(replyQObj, readAhead)
699699

700700
putmqmd, pmo, cfh, buf := statusSetCommandHeaders()
701+
701702
// Can allow all the other fields to default
702703
cfh.Command = ibmmq.MQCMD_DELETE_SUBSCRIPTION
703704

@@ -731,6 +732,9 @@ func clearDurableSubscriptions(prefix string, cmdQObj ibmmq.MQObject, replyQObj
731732

732733
}
733734

735+
// This tries to issue the "CLEAR QLOCAL" command for fast emptying of a queue during startup, before
736+
// we've actually opened the queue. This will fail if the queue is not a predefined local queue, but
737+
// we can ignore that error.
734738
func clearQPCF(qName string, cmdQObj ibmmq.MQObject, replyQObj ibmmq.MQObject, readAhead bool) {
735739
var err error
736740

0 commit comments

Comments
 (0)