From 48a4d2228e4a448e1b37470b48316e85876544e9 Mon Sep 17 00:00:00 2001 From: Al-Jami Ismail Date: Wed, 6 Dec 2023 16:16:20 -0500 Subject: [PATCH] Set queue passive to true (#150) --- src/SimulationService.jl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/SimulationService.jl b/src/SimulationService.jl index 5b4e1b5..4341fa3 100644 --- a/src/SimulationService.jl +++ b/src/SimulationService.jl @@ -248,7 +248,7 @@ function OperationRequest(req::HTTP.Request, route::String) if haskey(params, "queue") queue_name = params["queue"] queue_dict[o.id] = queue_name - AMQPClient.queue_declare(rabbitmq_channel[], queue_name;) + AMQPClient.queue_declare(rabbitmq_channel[], queue_name; passive=true) end for (k,v) in o.obj @@ -419,7 +419,7 @@ function get_dataset(obj::JSON3.Object) # there should always be a mapping from the dataset timestamp column name to 'timestamp' if !any(v -> v == "timestamp", values(obj.mappings)) - @error "Expected mapping from to 'timestamp' not provided" + @warn "Expected mapping from to 'timestamp' not provided" end for (k,v) in get(obj, :mappings, Dict())