Sha256: b80a362362fe3728f0e8c6fd5dfd4ceb8300db3d0e98bdc1f92b86c36de9553f
Contents?: true
Size: 763 Bytes
Versions: 6
Compression:
Stored size: 763 Bytes
Contents
###### CONTROL PORTS ######
# In dev, all of this runs on localhost, so we need different control
# ports
raise "No queue name set; -q on command line, or in config file" if !queue_name
ports = {}
QUEUES.each_with_index { |name, i|
ports[name] = CP_BASE_PORT + i
}
cp_port ports[queue_name]
###### QUEUE CONNECTION GRAPH ######
topology {
# Homes - this tells us where a given queue's process runs (a la
# hostname), and which host/port it listens on for connections.
hostname = `hostname`.chomp
QUEUES.each_with_index { |name, i|
queue(name) { |q|
q.located_at('localhost', QUEUE_BASE_PORT + i, hostname)
}
}
# Connections
queue('producer') {
writes_to('holder')
}
queue('consumer') {
reads_from('holder')
}
}
Version data entries
6 entries across 2 versions & 1 rubygems