Hook.io-amqp-listener is a project mainly written in COFFEESCRIPT and JAVASCRIPT, based on the MIT license.
An amqp listener that connects to a queue and forwards messages to the hook.io message bus
A hook that listens to an amqp queue and forwards messages to the hook.io message bus.
Scenario: You have a ruby/java/whatever front end app and want to decouple long running tasks, so you push messages into your amqp queue. Your backend processing is written in node.js, so you create a hook to do your backend work, and then connect amqp to your hook.io bus.
Caveat:
This is a very early version. Future versions will hopefully support the mapping of event names and acknowledging messages. Right now I just needed it to work.
Thanks a ton to @michaelklishin for helping me with amqp.
npm install -g hook.io-amqp-listener
./bin/hookio-amqp-listener
This starts a hook and reads the local config.json. It opens an amqp connection and listens to incoming messages
amqp-listener::add [in] Adds a queue listener. Make sure the tuple connection,queueName is added only once, otherwise all bets are off.
connection : "amqp[s]://[user:password@]hostname[:port][/vhost]",
queueName : "my-queue",
amqp-listener::error [out]
data: the data causing the error
error: The actual error
amqp-listener::received [out] Message will be sent for each received event unless that event has been name mapped.
queue: The queue name.
message: The message received.
contentType: The content type. The message is never pre processed.
deliveryMode: Passed verbatim from the delivery info. deliveryTag: Passed verbatim from the delivery info. redelivered: true if this message has been redelivered. exchange : The exchange this came from, or "" for the default exchange. routingKey : Passed verbatim from the delivery info. consumerTag : Passed verbatim from the delivery info.
The package config contains experimental hook.io schema definitions. The definition is also exported as hook. Signatures will be served from a signature server (more to come).
AmqpListener = require("hook.io-amqp-listener").AmqpListener
hook = new AmqpListener(name: 'amqp-listener')
var AmqpListener = require("hook.io-amqp-listener").AmqpListener;
var hook = new AmqpListener({ name: 'amqp-listener' });
Check out
Follow us on Twitter at
and like us on Facebook please. Every mention is welcome and we follow back.
Listened to lots of M.I.A. and Soundgarden while writing this.
Copyright (c) 2011 Martin Wawrusch. See LICENSE for further details.