diff --git a/src/NATSBridge.jl b/src/NATSBridge.jl index d32e8cc..3de00d4 100644 --- a/src/NATSBridge.jl +++ b/src/NATSBridge.jl @@ -363,16 +363,9 @@ function smartsend( data = url, metadata = Dict{String, Any}() ) - println("1 ----------") - PrettyPrinting.pprintln(payload) - println("1 ==========") push!(payloads, payload) end end - - println("2 ----------") - PrettyPrinting.pprintln(payloads) - println("2 ==========") # Create msgEnvelope_v1 with all payloads env = msgEnvelope_v1( @@ -394,10 +387,6 @@ function smartsend( msg_json = envelope_to_json(env) # Convert envelope to JSON publish_message(nats_url, subject, msg_json, cid) # Publish message to NATS - - println("3 ----------") - PrettyPrinting.pprintln(msg_json) - println("3 ==========") return env # Return the envelope for tracking end @@ -571,7 +560,6 @@ function smartreceive( ) # Parse the JSON envelope json_data = JSON.parse(String(msg.payload)) - PrettyPrinting.pprintln(json_data) log_trace(json_data["correlationId"], "Processing received message") # Log message processing start # Process all payloads in the envelope @@ -603,7 +591,6 @@ function smartreceive( log_trace(json_data["correlationId"], "Link transport - fetching '$dataname' from URL") # Log link transport handling # Extract download URL from the payload - PrettyPrinting.pprintln(payload) url = String(payload["data"]) # Fetch with exponential backoff using the download handler