feat(errorno): add new error no for transaction producer (#201)
diff --git a/include/CCommon.h b/include/CCommon.h
index f47f98c..0fbcbda 100644
--- a/include/CCommon.h
+++ b/include/CCommon.h
@@ -38,6 +38,7 @@
PRODUCER_SEND_ORDERLY_FAILED = 13,
PRODUCER_SEND_ASYNC_FAILED = 14,
PRODUCER_SEND_ORDERLYASYNC_FAILED = 15,
+ PRODUCER_SEND_TRANSACTION_FAILED = 16,
PUSHCONSUMER_ERROR_CODE_START = 20,
PUSHCONSUMER_START_FAILED = 20,
@@ -47,7 +48,8 @@
PULLCONSUMER_FETCH_MQ_FAILED = 31,
PULLCONSUMER_FETCH_MESSAGE_FAILED = 32,
- Not_Support = 500
+ Not_Support = 500,
+ NOT_SUPPORT_NOW = -1
} CStatus;
typedef enum _CLogLevel_ {
diff --git a/src/extern/CProducer.cpp b/src/extern/CProducer.cpp
index 4e8dabd..c95055c 100644
--- a/src/extern/CProducer.cpp
+++ b/src/extern/CProducer.cpp
@@ -595,7 +595,7 @@
result->msgId[MAX_MESSAGE_ID_LENGTH - 1] = 0;
} catch (exception& e) {
MQClientErrorContainer::setErr(string(e.what()));
- return PRODUCER_SEND_SYNC_FAILED;
+ return PRODUCER_SEND_TRANSACTION_FAILED;
}
return OK;
}