Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- # ใช้ gem ชื่อ bunny ในการต่อไปที่ RabbitMQ Server
- require "bunny"
- STDOUT.sync = true
- ## ต่อ RabbitMQ ผ่าน protocol amqp ด้วย user:guest , password: guest ไปที่ my-rabbit port 5672
- conn = Bunny.new("amqp://guest:guest@my-rabbit:5672")
- conn.start
- ## สร้าง Queue ที่ชื่อว่า "Test_Queue"
- ch = conn.create_channel
- q = ch.queue("Test_Queue", :durable => true)
- ## Publish Message ไปให้ Queue ที่เราสร้างไว้
- q.publish("Test Message", :timestamp => Time.now.to_i, :persistent => true)
- sleep 1.0
- conn.close
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement