LoginSignup
11
11

More than 5 years have passed since last update.

RabbitMQ + Node.jsサンプル

Last updated at Posted at 2014-06-11
amqp = require "amqp"

options =
  host: "localhost"
con = amqp.createConnection options

# 準備OK
con.on "ready", =>
  # キューに接続
  con.queue "tasklist", (q) =>

    # キューからデータを取得
    q.subscribe (message) =>
      console.log "### task", JSON.parse message.task

      # 終了
      con.disconnect()

    # 送信データ
    task =
      title: "write some articles"
      time: "12:00"
      estimate: "1h"
      description: "brabrabra"

    # キューにデータをプット
    con.publish "tasklist", task: JSON.stringify task
11
11
0

Register as a new user and use Qiita more conveniently

  1. You get articles that match your needs
  2. You can efficiently read back useful information
  3. You can use dark theme
What you can do with signing up
11
11