diff --git a/common/cpp/include/asapo/common/data_structs.h b/common/cpp/include/asapo/common/data_structs.h
index d29301909599de07885df777baac9747216cfe6c..be8b8497c24a2e4c75e691cad8f3caa0c0909d62 100644
--- a/common/cpp/include/asapo/common/data_structs.h
+++ b/common/cpp/include/asapo/common/data_structs.h
@@ -35,6 +35,7 @@ class MessageMeta {
   std::chrono::system_clock::time_point timestamp;
   uint64_t size{0};
   uint64_t id{0};
+  uint64_t message_id{0};  
   std::string source;
   std::string ib_source;
   std::string metadata;
diff --git a/common/cpp/src/data_structs/data_structs.cpp b/common/cpp/src/data_structs/data_structs.cpp
index 30869d441d9c376a7637dbb239716819cf392e2a..e32d4c4c163d67f88d53fbab70667fd1b4bcdf41 100644
--- a/common/cpp/src/data_structs/data_structs.cpp
+++ b/common/cpp/src/data_structs/data_structs.cpp
@@ -64,6 +64,7 @@ std::string MessageMeta::Json() const {
 
     int64_t buf_id_int = static_cast<int64_t>(buf_id);
     std::string s = "{\"_id\":" + std::to_string(id) + ","
+                    "\"message_id\":" + std::to_string(message_id) + ","
                     "\"size\":" + std::to_string(size) + ","
                     "\"name\":\"" + x + "\","
                     "\"timestamp\":"
diff --git a/receiver/src/request_handler/request_handler_db_write.cpp b/receiver/src/request_handler/request_handler_db_write.cpp
index 070559bff28c82e1dd053b6adce461d9835c615a..556ebd1797bb1e14ce5dfaaf60f53dc2b0bb37ec 100644
--- a/receiver/src/request_handler/request_handler_db_write.cpp
+++ b/receiver/src/request_handler/request_handler_db_write.cpp
@@ -77,7 +77,8 @@ MessageMeta RequestHandlerDbWrite::PrepareMessageMeta(const Request* request) co
     MessageMeta message_meta;
     message_meta.name = request->GetFileName();
     message_meta.size = request->GetDataSize();
-    message_meta.id = request->GetDataID();
+    message_meta.id = 0;
+    message_meta.message_id = request->GetDataID();
     message_meta.ingest_mode = request->GetIngestMode();
     message_meta.buf_id = request->GetSlotId();
     message_meta.stream = request->GetStream();