Skip to content

Commit

Permalink
Set queue passive to true (#150)
Browse files Browse the repository at this point in the history
  • Loading branch information
Jami159 authored Dec 6, 2023
1 parent 7ddfed9 commit 48a4d22
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/SimulationService.jl
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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 <dataset timestamp column> to 'timestamp' not provided"
@warn "Expected mapping from <dataset timestamp column> to 'timestamp' not provided"
end

for (k,v) in get(obj, :mappings, Dict())
Expand Down

0 comments on commit 48a4d22

Please sign in to comment.