Sha256: dc867c44048f1215563289761b67c2464884c8d949a650078316fe77e8a397b1

Contents?: true

Size: 548 Bytes

Versions: 3

Compression:

Stored size: 548 Bytes

Contents

$:.unshift File.expand_path(File.dirname(__FILE__))

require "bundler/setup"
require "amqp"
require "untied-consumer"
require "untied-consumer/worker"
require "daemons"

require "observer"

# Enabling the observer defined in observer.rb
Untied::Consumer.configure do |c|
  c.observers = [Observer]
end

log_dir = File.expand_path File.join(File.dirname(__FILE__), 'log')
pids_dir = File.expand_path File.join(File.dirname(__FILE__), 'tmp', 'pids')

worker = Untied::Consumer::Worker.new
worker.daemonize(:pids_dir => pids_dir, :log_dir => log_dir)

Version data entries

3 entries across 3 versions & 1 rubygems

Version Path
untied-0.0.7.pre3 examples/consumer-daemon/consumerd.rb
untied-0.0.5 examples/consumer-daemon/consumerd.rb
untied-0.0.4 examples/consumer-daemon/consumerd.rb