diff options
author | Azul <azul@leap.se> | 2012-09-01 13:43:17 +0200 |
---|---|---|
committer | Azul <azul@leap.se> | 2012-09-01 13:44:57 +0200 |
commit | f4968f6ed83130c1e8881a1a710e47819e5665a1 (patch) | |
tree | c8b5bed29c4119b4f1f38ec1a8224e3d109643e0 |
very initial test of tracking couchDB changes
http://joeandmotorboat.com/2010/01/01/fun-with-the-couchdb-_changes-feed-and-rabbitmq/ inspired the basic structure
-rw-r--r-- | test.rb | 23 |
1 files changed, 23 insertions, 0 deletions
@@ -0,0 +1,23 @@ +#!/usr/bin/ruby + +require 'rubygems' +require "yajl/http_stream" + +Signal.trap('INT') { AMQP.stop{ EM.stop } } +Signal.trap('TERM'){ AMQP.stop{ EM.stop } } + +def main + url = "http://localhost:5984/" + db = "test" + feed_type = "continuous" + since = "0" + queue = "changes" + + Yajl::HttpStream.get("#{url}#{db}/_changes?feed=#{feed_type}&since=#{since}", :symbolize_keys => true) do |hash| + if hash[:id] + #p hash + end + end +end + +main |