server/routing/end.rb in cpee-2.1.39 vs server/routing/end.rb in cpee-2.1.41

@@ -35,10 +35,10 @@
   end
 
   run do
     opts[:pubsubredis].psubscribe('callback-end:*') do |on|
       on.pmessage do |pat, what, message|
-        _, key = what.split(':')
+        _, worker, key = what.split(':',3)
         index = message.index(' ')
         instance = message[0...index]
         opts[:redis].multi do |multi|
           multi.srem("instance:#{instance}/callbacks",key)
           multi.del("instance:#{instance}/callback/#{key}/uuid")