From 60ae464ea20d50f7c9fc096994061e5208ea91d1 Mon Sep 17 00:00:00 2001
From: narawat <narawat@gmail.com>
Date: Wed, 13 May 2026 16:02:50 +0700
Subject: [PATCH] update

---
 src/NATSBridge.jl | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/NATSBridge.jl b/src/NATSBridge.jl
index fd152f5..ae65770 100644
--- a/src/NATSBridge.jl
+++ b/src/NATSBridge.jl
@@ -803,14 +803,15 @@ env = smartreceive(msg; fileserver_download_handler=_fetch_with_backoff, max_ret
 ```
 """
 function smartreceive(
-  msg::NATS.Msg;
+  msg_json_str::String; # get it from   String(nats_msg.payload)
   fileserver_download_handler::Function = _fetch_with_backoff,
   max_retries::Int = 5,
   base_delay::Int = 100,
   max_delay::Int = 5000
 )::JSON.Object{String, Any}
+
   # Parse the JSON envelope
-  env_json_obj = JSON.parse(String(msg.payload))
+  env_json_obj = JSON.parse(msg_json_str)
   log_trace(env_json_obj["correlation_id"], "Processing received message")  # Log message processing start
   
   # Process all payloads in the envelope