ton/NATSBridge
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

add_mix_content_capability #2

Merged
ton merged 25 commits from add_mix_content_capability into main 2026-02-19 12:27:59 +00:00
Conversation 0 Commits 25 Files Changed 38 -13
1 changed files with 0 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 82804c6803 - Show all commits

13
src/NATSBridge.jl
View File

@@ -363,17 +363,10 @@ function smartsend(
data = url, data = url,
metadata = Dict{String, Any}() metadata = Dict{String, Any}()
) )
println("1 ----------")
PrettyPrinting.pprintln(payload)
println("1 ==========")
push!(payloads, payload) push!(payloads, payload)
end end
end end
println("2 ----------")
PrettyPrinting.pprintln(payloads)
println("2 ==========")
# Create msgEnvelope_v1 with all payloads # Create msgEnvelope_v1 with all payloads
env = msgEnvelope_v1( env = msgEnvelope_v1(
correlationId = cid, correlationId = cid,
@@ -395,10 +388,6 @@ function smartsend(
msg_json = envelope_to_json(env) # Convert envelope to JSON msg_json = envelope_to_json(env) # Convert envelope to JSON
publish_message(nats_url, subject, msg_json, cid) # Publish message to NATS 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 return env # Return the envelope for tracking
end end
@@ -571,7 +560,6 @@ function smartreceive(
) )
# Parse the JSON envelope # Parse the JSON envelope
json_data = JSON.parse(String(msg.payload)) json_data = JSON.parse(String(msg.payload))
PrettyPrinting.pprintln(json_data)
log_trace(json_data["correlationId"], "Processing received message") # Log message processing start log_trace(json_data["correlationId"], "Processing received message") # Log message processing start
# Process all payloads in the envelope # 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 log_trace(json_data["correlationId"], "Link transport - fetching '$dataname' from URL") # Log link transport handling
# Extract download URL from the payload # Extract download URL from the payload
PrettyPrinting.pprintln(payload)
url = String(payload["data"]) url = String(payload["data"])
# Fetch with exponential backoff using the download handler # Fetch with exponential backoff using the download handler