blob: 7882e0c8f3d2f8d125f92009851ccbaef861bfc4 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
[global]
# Enable message output at different stages in the app.
super_debug = true
# Number of maximum sockets to open per context/process.
max_sockets = 1024
# Hide the heartbeat logs when super_debug is enabled. Showing them will generate a lot of messages.
hide_heartbeat_logs = True
# Port to listen on for administrative commands sent via emq-cli
administrative_addr=tcp://0.0.0.0:47293
frontend_addr=tcp://0.0.0.0:47291
backend_addr=tcp://0.0.0.0:47290
worker_addr=tcp://eventmq:47290
scheduler_addr=tcp://eventmq:47291
[router]
[scheduler]
redis_client_class = redis.StrictRedis
[jobmanager]
worker_addr=tcp://127.0.0.1:47290
# Defines the weight and name of queues this worker deals with.
queues=[[20,"heavy-cpu"], [30,"low-cpu"], [10,"default"]]
# Specifies the number of of sub-processes to spawn to process jobs concurrently
concurrent_jobs=2
# This function is executed when EventMQ creates a new worker subprocess
# subprocess_setup_func = path.to.my_setup_function
# This function is executed before every job
# job_entry_func = path.to.my_job_setup_function
# This function is executed after every job
# job_exit_func = path.to.my_job_teardown_function
[publisher]
publisher_incoming_addr=tcp://0.0.0.0:47298
publisher_outgoing_addr=tcp://0.0.0.0:47299
|
