diff --git a/indexer/services/vulcan/src/lib/on-message.ts b/indexer/services/vulcan/src/lib/on-message.ts
index 590799439a..cc81a9a326 100644
--- a/indexer/services/vulcan/src/lib/on-message.ts
+++ b/indexer/services/vulcan/src/lib/on-message.ts
@@ -122,10 +122,10 @@ export async function onMessage(message: KafkaMessage): Promise<void> {
     await handler.handleUpdate(update, headers);
 
     const postProcessingTime: number = Date.now();
-    if (originalMessageTimestamp !== undefined) {
+    if (headers.message_received_timestamp !== undefined) {
       stats.timing(
         `${config.SERVICE_NAME}.message_time_since_received_post_processing`,
-        postProcessingTime - Number(originalMessageTimestamp),
+        postProcessingTime - Number(headers.message_received_timestamp),
         STATS_NO_SAMPLING,
         {
           topic: KafkaTopics.TO_VULCAN,