Skip to content

Commit 606f943

Browse files
committed
Need to check if there really was an error
1 parent 44e1f1e commit 606f943

File tree

1 file changed

+10
-8
lines changed

1 file changed

+10
-8
lines changed

mqmetric/mqif.go

Lines changed: 10 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -159,15 +159,17 @@ func getMessage(wait bool) ([]byte, error) {
159159
}
160160

161161
datalen, err = replyQObj.Get(getmqmd, gmo, getBuffer)
162-
mqreturn = err.(*ibmmq.MQReturn)
162+
if err != nil {
163+
mqreturn = err.(*ibmmq.MQReturn)
163164

164-
if mqreturn.MQRC == ibmmq.MQRC_Q_MGR_NOT_AVAILABLE ||
165-
mqreturn.MQRC == ibmmq.MQRC_Q_MGR_NAME_ERROR ||
166-
mqreturn.MQRC == ibmmq.MQRC_Q_MGR_QUIESCING {
167-
log.Fatal("Queue Manager error: ", err)
168-
}
169-
if mqreturn.MQCC == ibmmq.MQCC_FAILED && mqreturn.MQRC != ibmmq.MQRC_NO_MSG_AVAILABLE {
170-
log.Error("Get message: ", err)
165+
if mqreturn.MQRC == ibmmq.MQRC_Q_MGR_NOT_AVAILABLE ||
166+
mqreturn.MQRC == ibmmq.MQRC_Q_MGR_NAME_ERROR ||
167+
mqreturn.MQRC == ibmmq.MQRC_Q_MGR_QUIESCING {
168+
log.Fatal("Queue Manager error: ", err)
169+
}
170+
if mqreturn.MQCC == ibmmq.MQCC_FAILED && mqreturn.MQRC != ibmmq.MQRC_NO_MSG_AVAILABLE {
171+
log.Error("Get message: ", err)
172+
}
171173
}
172174

173175
return getBuffer[0:datalen], err

0 commit comments

Comments
 (0)