diff options
-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 |