diff --git a/docs/architecture.md b/docs/architecture.md index 82a8dea..2bb2812 100644 --- a/docs/architecture.md +++ b/docs/architecture.md @@ -160,7 +160,7 @@ end "brokerURL": "nats://localhost:4222", "metadata": { - + }, "payloads": [ @@ -327,7 +327,7 @@ function smartsend( ```julia function smartreceive( msg::NATS.Message, - fileserverDownloadHandler::Function=_fetch_with_backoff; + fileserverDownloadHandler::Function; max_retries::Int = 5, base_delay::Int = 100, max_delay::Int = 5000 diff --git a/src/NATSBridge.jl b/src/NATSBridge.jl index 010a3e4..5e4786e 100644 --- a/src/NATSBridge.jl +++ b/src/NATSBridge.jl @@ -341,10 +341,10 @@ function smartsend( response = fileserverUploadHandler(fileserver_url, dataname, payload_bytes) if response["status"] != 200 # Check if upload was successful - error("Failed to upload data to fileserver: $(response[:status])") # Throw error if upload failed + error("Failed to upload data to fileserver: $(response["status"])") # Throw error if upload failed end - url = response[:url] # URL for the uploaded data + url = response["url"] # URL for the uploaded data log_trace(cid, "Uploaded to URL: $url") # Log successful upload # Create msgPayload_v1 for link transport