@@ -77,6 +77,7 @@ TEST(cProducer, SendMessageAsync) {
7777 EXPECT_CALL (*mockProducer, send (_, _)).Times (1 );
7878 EXPECT_EQ (SendMessageAsync (cProducer, msg, cSendSuccessCallback, cSendExceptionCallback), OK);
7979 Mock::AllowLeak (mockProducer);
80+ DestroyMessage (msg);
8081}
8182
8283TEST (cProducer, sendMessageOrderly) {
@@ -97,6 +98,8 @@ TEST(cProducer, sendMessageOrderly) {
9798 .WillOnce (Return (SendResult (SendStatus::SEND_OK, " 3" , " offset1" , messageQueue, 14 )));
9899 // EXPECT_EQ(SendMessageOrderly(cProducer, msg, callback, msg, 1, result), OK);
99100 Mock::AllowLeak (mockProducer);
101+ DestroyMessage (msg);
102+ // free(result);
100103}
101104
102105TEST (cProducer, sendOneway) {
@@ -110,6 +113,7 @@ TEST(cProducer, sendOneway) {
110113 EXPECT_CALL (*mockProducer, sendOneway (_, _)).Times (1 );
111114 EXPECT_EQ (SendMessageOneway (cProducer, msg), OK);
112115 Mock::AllowLeak (mockProducer);
116+ DestroyMessage (msg);
113117}
114118
115119TEST (cProducer, sendMessageSync) {
@@ -150,7 +154,8 @@ TEST(cProducer, sendMessageSync) {
150154 EXPECT_EQ (SendMessageSync (cProducer, msg, result), OK);
151155 EXPECT_EQ (result->sendStatus , E_SEND_OK);
152156 Mock::AllowLeak (mockProducer);
153- delete mqMessage;
157+ DestroyMessage (msg);
158+ free (result);
154159}
155160
156161TEST (cProducer, infoMock) {
0 commit comments