DaemonKit::Application.running! do |config|
end
class ApiServer
def call(env)
req = Rack::Request.new(env)
[200, {"Content-Type" => "text/html"}, ["Hello Rack!"]]
end
end
Rack::Handler::Mongrel.run ApiServer.new, :Port => 9292
# IMPORTANT CONFIGURATION NOTE
#
# Please review and update 'config/amqp.yml' accordingly or this
# daemon won't work as advertised.
# Run an event-loop for processing
DaemonKit::AMQP.run do |connection|
# Inside this block we're running inside the reactor setup by the
# amqp gem. Any code in the examples (from the gem) would work just
# fine here.
# Uncomment this for connection keep-alive
# connection.on_tcp_connection_loss do |client, settings|
# DaemonKit.logger.debug("AMQP connection status changed: #{status}")
# client.reconnect(false, 1)
# end
amq = AMQP::Channel.new
amq.queue('test').subscribe do |msg|
DaemonKit.logger.debug "Received message: #{msg.inspect}"
end
end
--
You received this message because you are subscribed to the Google Groups "Daemon Kit" group.
To unsubscribe from this group and stop receiving emails from it, send an email to daemon-kit+...@googlegroups.com.
To post to this group, send email to daemo...@googlegroups.com.
Visit this group at http://groups.google.com/group/daemon-kit.
For more options, visit https://groups.google.com/groups/opt_out.