Skip to content

Commit 87300dd

Browse files
authored
Merge pull request #487 from Cousjava/cclient-memoryleak
Fix for memory leak in C client from expired messages
2 parents 627e16c + aacf4b9 commit 87300dd

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

mq/src/share/cclient/client/MessageConsumer.cpp

+3-1
Original file line numberDiff line numberDiff line change
@@ -562,9 +562,11 @@ MessageConsumer::receive(Message ** const message,
562562
if (this->isDMQConsumer == PR_FALSE && ((*message)->isExpired()) == PR_TRUE) {
563563
ERRCHK( session->acknowledgeExpiredMessage(*message) );
564564
this->session->messageDelivered();
565+
DELETE( packet );
566+
HANDLED_DELETE( *message );
565567
receiveQueue->receiveDone();
566568
continue;
567-
}
569+
}
568570

569571
if (this->hasLastDeliveredSysMessageID == PR_FALSE) {
570572
this->hasLastDeliveredSysMessageID = PR_TRUE;

0 commit comments

Comments
 (0)