diff --git a/include/CCommon.h b/include/CCommon.h index f47f98c42..0fbcbdadf 100644 --- a/include/CCommon.h +++ b/include/CCommon.h @@ -38,6 +38,7 @@ typedef enum _CStatus_ { 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 @@ typedef enum _CStatus_ { 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 4e8dabdc2..c95055c36 100644 --- a/src/extern/CProducer.cpp +++ b/src/extern/CProducer.cpp @@ -595,7 +595,7 @@ int SendMessageTransaction(CProducer* producer, 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; }