diff --git a/src/NATSBridge.jl b/src/NATSBridge.jl index 95f9db5..b0f781e 100644 --- a/src/NATSBridge.jl +++ b/src/NATSBridge.jl @@ -300,19 +300,7 @@ function envelope_to_json(env::msg_envelope_v1) "encoding" => payload.encoding, "size" => payload.size, ) - # Include data based on transport type - if payload.transport == "direct" && payload.data !== nothing - if payload.encoding == "base64" || payload.encoding == "json" || payload.encoding == "arrow-ipc" - payload_obj["data"] = payload.data - else - # For other encodings, use base64 - payload_bytes = _get_payload_bytes(payload.data) - payload_obj["data"] = Base64.base64encode(payload_bytes) - end - elseif payload.transport == "link" && payload.data !== nothing - # For link transport, data is a URL string - include directly - payload_obj["data"] = payload.data - end + payload_obj["data"] = payload.data if !isempty(payload.metadata) payload_obj["metadata"] = Dict(String(k) => v for (k, v) in payload.metadata) end