lib/peatio/amqp/queue.rb
# enqueue = publish to direct exchange
enqueue = publish to direct exchange
enqueue = publish to direct exchange
def enqueue(id, payload, attrs={})
        eid = AMQP::Config.binding_exchange_id(id) || :default
        attrs.merge!({routing_key: AMQP::Config.routing_key(id)})
        publish(eid, payload, attrs)
      end
def enqueue ( id , payload , attrs = { } ) eid = AMQP :: Config . binding_exchange_id ( id ) || :default attrs . merge! ( { routing_key : AMQP :: Config . routing_key ( id ) } ) publish ( eid , payload , attrs ) end
enqueue = publish to direct exchange
enqueue = publish to direct exchange
id
payload
attrs