Skip to content
This repository was archived by the owner on Apr 7, 2025. It is now read-only.

Commit c2c95b7

Browse files
authored
Use env var for rabbitmq host (#115)
1 parent ab7d5fc commit c2c95b7

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/SimulationService.jl

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,6 +55,7 @@ const RABBITMQ_ENABLED = Ref{Bool}()
5555
const RABBITMQ_LOGIN = Ref{String}()
5656
const RABBITMQ_PASSWORD = Ref{String}()
5757
const RABBITMQ_ROUTE = Ref{String}()
58+
const RABBITMQ_HOST = Ref{String}()
5859
const RABBITMQ_PORT = Ref{Int}()
5960

6061
function __init__()
@@ -75,13 +76,14 @@ function __init__()
7576
RABBITMQ_LOGIN[] = get(ENV, "SIMSERVICE_RABBITMQ_LOGIN", "guest")
7677
RABBITMQ_PASSWORD[] = get(ENV, "SIMSERVICE_RABBITMQ_PASSWORD", "guest")
7778
RABBITMQ_ROUTE[] = get(ENV, "SIMSERVICE_RABBITMQ_ROUTE", "sciml-queue")
79+
RABBITMQ_HOST[] = get(ENV, "SIMSERVICE_RABBITMQ_HOST", "localhost")
7880
RABBITMQ_PORT[] = parse(Int, get(ENV, "SIMSERVICE_RABBITMQ_PORT", "5672"))
7981

8082
if RABBITMQ_ENABLED[]
8183
auth_params = Dict{String,Any}(
8284
("MECHANISM" => "AMQPLAIN", "LOGIN" => RABBITMQ_LOGIN[], "PASSWORD" => RABBITMQ_PASSWORD[])
8385
)
84-
conn = AMQPClient.connection(; virtualhost="/", host="localhost", port=RABBITMQ_PORT[], auth_params)
86+
conn = AMQPClient.connection(; virtualhost="/", host=RABBITMQ_HOST[], port=RABBITMQ_PORT[], auth_params)
8587

8688
rabbitmq_channel[] = AMQPClient.channel(conn, AMQPClient.UNUSED_CHANNEL, true)
8789
AMQPClient.queue_declare(rabbitmq_channel[], RABBITMQ_ROUTE[]; durable=true)

0 commit comments

Comments
 (0)