blob: 7b4d50e916a7868f9d443e992da0f272bc9ed4ec (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
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
|
