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

update

Browse Source
This commit is contained in:
narawat
2026-08-28 08:11:35 +07:00
parent 139feb9e4f
commit 72b909a50c
1 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/msghandler.jl
+1 -5
View File
@@ -414,10 +414,6 @@ env, msg_json = smartpack("chat.subject", [
("audio_clip", audio_data, "audio") ("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) # Custom fileserver upload handler (e.g., for AWS S3)
function my_custom_upload(fileserver_url::String, dataname::String, data::Vector{UInt8})::Dict{String, Any} 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 # 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") # Dict("status" => 200, "uploadid" => "abc123", "fileid" => "file456", "url" => "http://my-server.com/abc123/file456/myfile.bin")
throw(NotImplementedError("implement upload logic here")) throw(NotImplementedError("implement upload logic here"))
end end
env, msg_json = smartpack("my.subject", [("data", large_binary_data, "binary")], fileserver_upload_handler=my_custom_upload)
``` ```
""" """
function smartpack( function smartpack(
@@ -446,6 +441,7 @@ function smartpack(
# stage of the execution pipeline. It serves as the end-to-end ID for # stage of the execution pipeline. It serves as the end-to-end ID for
# distributed tracing, enabling the correlation of all logs, metrics, and # distributed tracing, enabling the correlation of all logs, metrics, and
# errors across the system back to this specific request instance. # errors across the system back to this specific request instance.
correlation_id::String = string(uuid4()), correlation_id::String = string(uuid4()),
msg_purpose::String = "chat", msg_purpose::String = "chat",