Projects
home:rottame:yggdra_agents
mailserver_agent
Log In
Username
Password
Overview
Repositories
Revisions
Requests
Users
Attributes
Meta
Expand all
Collapse all
Changes of Revision 4
View file
mailserver_agent-1.0.0.tar.gz/lib/tomte/workers/mailserver_worker_pubsub.rb
Changed
@@ -2,10 +2,14 @@ class MailServerWorkerPubsub < Tomte::Worker bus :service, :enveloper => Tomte::Protocol::Enveloper::Generic do |ep| - consumer = ep.consumer :queue => "ygg.email.events.#{Tomte.config[:local][:hostname]}", :ack => false + consumer = ep.consumer :queue => "ygg.email.events.#{Tomte.config[:local][:host]}", :ack => false consumer.connect! do |c| + c.declare_exchange('ygg.email.events', :topic, :auto_delete => true) do + c.bind('ygg.email.events') + c.consume { log.info "ready to receive messages on ygg.email.events" } + end + consumer.prefetch 1 - c.bind("ygg.email.events") c.consume { log.info "ready to receive messages" } log.debug '+ Sync database'
Locations
Projects
Search
Status Monitor
Help
Open Build Service
OBS Manuals
API Documentation
OBS Portal
Reporting a Bug
Contact
Mailing List
Forums
Chat (IRC)
Twitter
Open Build Service (OBS)
is an
openSUSE project
.