server/routing/forward-events.rb in cpee-2.1.12 vs server/routing/forward-events.rb in cpee-2.1.13
- old
+ new
@@ -28,11 +28,11 @@
on startup do
opts[:redis_path] ||= '/tmp/redis.sock'
opts[:redis_db] ||= 1
- CPEE::redis_connect opts
- opts[:pubsubredis] = opts[:redis_dyn].call
+ CPEE::redis_connect opts, 'Server Routing Forward Events'
+ opts[:pubsubredis] = opts[:redis_dyn].call 'Server Routing Forward Events Sub'
end
run do
opts[:pubsubredis].psubscribe('event:*') do |on|
on.pmessage do |pat, what, message|