Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

remove old unused subscriptions

  • Loading branch information...
commit b49a77176f3c51b8d35ecf9606fc59ddefb2c687 1 parent 6905fda
@joshk joshk authored drogus committed
Showing with 2 additions and 15 deletions.
  1. +2 −15 lib/travis/hub/queues.rb
View
17 lib/travis/hub/queues.rb
@@ -12,26 +12,13 @@ def self.subscribe
def subscribe
info 'Subscribing to amqp ...'
- subscribe_to_build_requests_and_syncs
subscribe_to_reporting
subscribe_to_worker_status
end
- def subscribe_to_build_requests_and_syncs
- queues = ['builds.requests', 'builds.requests', 'sync.user']
- queues.each do |queue|
- info "Subscribing to #{queue}"
- Travis::Amqp::Consumer.new(queue).subscribe(:ack => true, &method(:receive))
- end
- end
-
def subscribe_to_reporting
- # TODO should be just 'builds', once we're on bluebox
- queues = ['builds', 'builds.common'] + Travis.config.queues.map { |queue| queue[:queue] }
- queues.uniq.each do |name|
- info "Subscribing to #{name}"
- Travis::Amqp::Consumer.jobs(name).subscribe(:ack => true, &method(:receive))
- end
+ info "Subscribing to reporting.jobs.builds"
+ Travis::Amqp::Consumer.jobs('builds').subscribe(:ack => true, &method(:receive))
end
def subscribe_to_worker_status
Please sign in to comment.
Something went wrong with that request. Please try again.