joewilliams (owner)

Revisions

gist: 124716 Download_button fork
public
Public Clone URL: git://gist.github.com/124716.git
Embed All Files: show embed
couch_amqp.rb #
raw 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

#!/usr/bin/ruby
 
require 'rubygems'
require 'carrot'
 
def main
  queue = "couchdb"
  run = true
  couchq = Carrot.queue(:queue => queue)
 
  while run do
 
    notifications = gets
 
    if notifications == nil
      run = false
    else
      couchq.publish(notifications)
    end
 
  end
end
 
main