From 72b909a50c481a5d141ec4016c37b4c3257ccf63 Mon Sep 17 00:00:00 2001 From: narawat Date: Fri, 28 Aug 2026 08:11:35 +0700 Subject: [PATCH] update --- src/msghandler.jl | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/src/msghandler.jl b/src/msghandler.jl index 3bcc33e..cafa90b 100644 --- a/src/msghandler.jl +++ b/src/msghandler.jl @@ -414,10 +414,6 @@ env, msg_json = smartpack("chat.subject", [ ("audio_clip", audio_data, "audio") ]) -# Publish the JSON string directly via your transport (manual publish) -# conn = my_transport.connect(broker_url) -# my_transport.publish(conn, subject, env_json_str) - # Custom fileserver upload handler (e.g., for AWS S3) function my_custom_upload(fileserver_url::String, dataname::String, data::Vector{UInt8})::Dict{String, Any} # Upload `data` to your file server at `fileserver_url`, using `dataname` as the file name @@ -430,7 +426,6 @@ function my_custom_upload(fileserver_url::String, dataname::String, data::Vector # Dict("status" => 200, "uploadid" => "abc123", "fileid" => "file456", "url" => "http://my-server.com/abc123/file456/myfile.bin") throw(NotImplementedError("implement upload logic here")) end -env, msg_json = smartpack("my.subject", [("data", large_binary_data, "binary")], fileserver_upload_handler=my_custom_upload) ``` """ function smartpack( @@ -446,6 +441,7 @@ function smartpack( # stage of the execution pipeline. It serves as the end-to-end ID for # distributed tracing, enabling the correlation of all logs, metrics, and # errors across the system back to this specific request instance. + correlation_id::String = string(uuid4()), msg_purpose::String = "chat",