Add JMSException on Commit and Rollback response to allow error handling - #32

Author: matrober-uk

jms20subset/JMSContext.go

@@ -69,10 +69,10 @@ type JMSContext interface {
 	CreateBytesMessageWithBytes(bytes []byte) BytesMessage
 
 	// Commit confirms all messages sent/received during this transaction.
-	Commit()
+	Commit() JMSException
 
 	// Rollback releases all messages sent/received during this transaction.
-	Rollback()
+	Rollback() JMSException
 
 	// Closes the connection to the messaging provider.
 	//

mqjms/ContextImpl.go

@@ -138,21 +138,47 @@ func (ctx ContextImpl) CreateBytesMessageWithBytes(bytes []byte) jms20subset.Byt
 }
 
 // Commit confirms all messages that were sent under this transaction.
-func (ctx ContextImpl) Commit() {
+func (ctx ContextImpl) Commit() jms20subset.JMSException {
+
+	var retErr jms20subset.JMSException
 
 	if (ibmmq.MQQueueManager{}) != ctx.qMgr {
-		ctx.qMgr.Cmit()
+		err := ctx.qMgr.Cmit()
+
+		if err != nil {
+
+			rcInt := int(err.(*ibmmq.MQReturn).MQRC)
+			errCode := strconv.Itoa(rcInt)
+			reason := ibmmq.MQItoString("RC", rcInt)
+			retErr = jms20subset.CreateJMSException(reason, errCode, err)
+
+		}
+
 	}
 
+	return retErr
 }
 
 // Rollback releases all messages that were sent under this transaction.
-func (ctx ContextImpl) Rollback() {
+func (ctx ContextImpl) Rollback() jms20subset.JMSException {
+
+	var retErr jms20subset.JMSException
 
 	if (ibmmq.MQQueueManager{}) != ctx.qMgr {
-		ctx.qMgr.Back()
+		err := ctx.qMgr.Back()
+
+		if err != nil {
+
+			rcInt := int(err.(*ibmmq.MQReturn).MQRC)
+			errCode := strconv.Itoa(rcInt)
+			reason := ibmmq.MQItoString("RC", rcInt)
+			retErr = jms20subset.CreateJMSException(reason, errCode, err)
+
+		}
 	}
 
+	return retErr
+
 }
 
 // Close this connection to the MQ queue manager, and release any resources