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