class MessageDriver::Adapters::BunnyAdapter::Destination
Public Instance Methods
exchange_name()
click to toggle source
# File lib/message_driver/adapters/bunny_adapter.rb, line 49 def exchange_name @name end
publish_params(body, headers, properties)
click to toggle source
# File lib/message_driver/adapters/bunny_adapter.rb, line 42 def publish_params(body, headers, properties) b, h, p = middleware.on_publish(body, headers, properties) props = @message_props.merge(p) props[:headers] = h if h [b, exchange_name, routing_key(properties), props] end
routing_key(properties)
click to toggle source
# File lib/message_driver/adapters/bunny_adapter.rb, line 53 def routing_key(properties) properties[:routing_key] end