Projects
home:rottame:yggdra_agents
mail_agent
Log In
Username
Password
Overview
Repositories
Revisions
Requests
Users
Attributes
Meta
Expand all
Collapse all
Changes of Revision 5
View file
mail_agent-1.0.0.tar.gz/Makefile
Changed
@@ -11,6 +11,7 @@ -v ${PWD}:/mail_agent \ --add-host=hel.dev.me:10.0.3.100 \ --add-host=hel.local.me:192.168.193.198 \ + --add-host=hel.staging.me:192.168.193.197 \ mail_agent \ ./bin/mail_agent -e development -D @@ -18,6 +19,8 @@ docker run -ti --rm \ -v ${PWD}:/mail_agent \ --add-host=hel.dev.me:10.0.3.100 \ + --add-host=hel.local.me:192.168.193.198 \ + --add-host=hel.staging.me:192.168.193.197 \ mail_agent \ bash
View file
mail_agent-1.0.0.tar.gz/lib/tomte/workers/mail_worker_pubsub.rb
Changed
@@ -2,10 +2,14 @@ class MailWorkerPubsub < Tomte::Worker bus :service, :enveloper => Tomte::Protocol::Enveloper::Generic do |ep| - consumer = ep.consumer :queue => "ygg.email.events", :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
.