lib/resque_bus/subscription.rb in resque-bus-0.2.7 vs lib/resque_bus/subscription.rb in resque-bus-0.2.8
- old
+ new
@@ -31,10 +31,12 @@
@executor = executor
end
def execute!(attributes)
attributes = attributes.with_indifferent_access if attributes.respond_to?(:with_indifferent_access)
- executor.call(attributes)
+ ResqueBus.with_global_attributes(attributes) do
+ executor.call(attributes)
+ end
end
def matches?(attributes)
@matcher.matches?(attributes)
end
\ No newline at end of file