特拉菲克
Traffiq可以帮助您解决队列问题,因此您不必这样做。
用法
目前,主题交流仅支持AMQP。
# consumer.rb
amqp = Traffiq :: AMQP . new ( "user:password@rabbit-server.com" )
amqp . define_exchange ( 'events' , durable : true )
amqp . subscribe ( 'routing_key' , options ) do | delivery_info , metadata , payload |
puts delivery_info , metadata , payload
end
# producer.rb
amqp = Traffiq :: AMQP . new ( queue_url )
amqp