fix segmentation failed.

shibd · Dec 4, 2023 · 7d15f51 · 7d15f51
1 parent 6b97ee8
commit 7d15f51
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/Consumer.cc b/src/Consumer.cc
@@ -291,10 +291,13 @@ Napi::Value Consumer::BatchReceive(const Napi::CallbackInfo &info) {
             Napi::Array jsArray = Napi::Array::New(env, listSize);
             for (int i = 0; i < listSize; i++) {
               pulsar_message_t *rawMessage = pulsar_messages_get(rawMessages, i);
+              pulsar_message_t *message = pulsar_message_create();
+              pulsar_message_copy(rawMessage, message);
               Napi::Object obj = Message::NewInstance(
-                  {}, std::shared_ptr<pulsar_message_t>(rawMessage, pulsar_message_free));
+                  {}, std::shared_ptr<pulsar_message_t>(message, pulsar_message_free));
               jsArray.Set(i, obj);
             }
+            pulsar_messages_free(rawMessages);
             return jsArray;
           });
         }