summaryrefslogtreecommitdiff
path: root/lib/tapicero_daemon.rb
diff options
context:
space:
mode:
authorelijah <elijah@riseup.net>2015-03-17 15:06:54 -0700
committerelijah <elijah@riseup.net>2015-03-17 15:06:54 -0700
commit74a8f39a0d91f7f992c41cced01f80f24001e173 (patch)
tree2c459d89ed9d1e284098dc43715db813eab97f27 /lib/tapicero_daemon.rb
parent2d42b4a39eaa346b94fa4aa2bb90bebb5621112e (diff)
parent25b34acce7612f58c5d40819de79734b08cdfb8f (diff)
Merge branch 'develop' into version/0.6.1version/0.6.1
Conflicts: Gemfile.lock
Diffstat (limited to 'lib/tapicero_daemon.rb')
-rw-r--r--lib/tapicero_daemon.rb20
1 files changed, 8 insertions, 12 deletions
diff --git a/lib/tapicero_daemon.rb b/lib/tapicero_daemon.rb
index 86f924e..26f8e00 100644
--- a/lib/tapicero_daemon.rb
+++ b/lib/tapicero_daemon.rb
@@ -5,23 +5,19 @@
# Daemons.run('tapicero_daemon.rb')
#
require 'tapicero'
+require 'tapicero/loop'
require 'extends/couchrest'
require 'tapicero/user_event_handler'
module Tapicero
module Daemon
- while true
- begin
- users = CouchRest::Changes.new('users')
- UserEventHandler.new(users)
- users.listen
- Tapicero.logger.info('Lost contact with couchdb, will try again in 10 seconds')
- sleep 10
- rescue SystemCallError => exc
- Tapicero.logger.info('Problem connecting to couchdb (#{exc}). Will try again in 10 seconds.')
- sleep 10
- retry
- end
+ users_thread = Thread.new do
+ Tapicero::Loop.new.listen('users')
end
+ tmp_users_thread = Thread.new do
+ Tapicero::Loop.new.listen('tmp_users')
+ end
+ users_thread.join
+ tmp_users_thread.join
end
end