CreateMessage but without DestroyMessage for example AsyncProducer and SyncProducer in CAsyncProducer.c and Producer.c void startSendMessage(CProducer *producer) { ........ CMessage *msg = CreateMessage("T_TestTopic"); for (i = 0; i < 10; i++) { ....... } }