summaryrefslogtreecommitdiff
path: root/exe/killjoy
diff options
context:
space:
mode:
Diffstat (limited to 'exe/killjoy')
-rwxr-xr-xexe/killjoy10
1 files changed, 3 insertions, 7 deletions
diff --git a/exe/killjoy b/exe/killjoy
index 53985f6..c22e9e9 100755
--- a/exe/killjoy
+++ b/exe/killjoy
@@ -5,18 +5,14 @@ $LOAD_PATH.unshift(File.expand_path("../lib", File.dirname(__FILE__)))
require "killjoy"
require "killjoy/server"
-shards = ENV.fetch("RMQ_SHARDS", 4).to_i
-
+configuration = Killjoy::AMQPConfiguration.new
server = ServerEngine::Daemon.new(Killjoy::Server, Killjoy::Worker, {}) do
{
- amqp_uri: ENV.fetch("RABBITMQ_URL", "amqp://guest:guest@localhost:5672"),
daemonize: false,
- exchange: 'killjoy',
- exchange_type: 'x-modulus-hash',
pid_path: 'tmp/killjoy.pid',
- queue_shards: shards,
+ queue_shards: configuration.shards,
worker_type: 'process',
- workers: shards,
+ workers: configuration.shards,
}
end
server.run