diff --git a/lib/resque_bus/server/views/bus.erb b/lib/resque_bus/server/views/bus.erb index ed14a27..6636f2d 100644 --- a/lib/resque_bus/server/views/bus.erb +++ b/lib/resque_bus/server/views/bus.erb @@ -44,6 +44,7 @@ else class_name = sub.class_name queue = sub.queue_name filters = sub.matcher.filters + sub_key = sub.key if filters["bus_event_type"] event = filters["bus_event_type"] @@ -52,13 +53,13 @@ else end app_hash[app_key] ||= [] - app_hash[app_key] << [event, class_name, queue, filters] + app_hash[app_key] << [sub_key, event, class_name, queue, filters] class_hash[class_name] ||= [] - class_hash[class_name] << [app_key, event, queue, filters] + class_hash[class_name] << [app_key, sub_key, event, queue, filters] event_hash[event] ||= [] - event_hash[event] << [app_key, class_name, queue, filters] + event_hash[event] << [app_key, sub_key, class_name, queue, filters] end end @@ -81,8 +82,8 @@ else if !val out = "  " else - one, two, queue, filters = val - out = "#{h(one)}#{h(two)}#{h(queue)}" + one, two, three, queue, filters = val + out = "#{h(one)}#{h(two)}#{h(three)}#{h(queue)}" out << "#{h(::QueueBus::Util.encode(filters).gsub(/\"bus_special_value_(\w+)\"/){ "(#{$1})" }).gsub(" ", " ").gsub('","', '", "')}" end @@ -138,6 +139,7 @@ else + @@ -155,6 +157,7 @@ else + @@ -172,6 +175,7 @@ else +
App KeySubscription Key Event Type Class Name Queue
Event Type App KeySubscription Key Class Name Queue Filters
Class Name App KeySubscription Key Event Type Queue Filters