Contents

require 'resque-bus'
require 'resque/server'
require 'erb'

# MIGRATE TODO: move to resque gem
# Extend ::Resque::Server to add tabs.
module ResqueBus
  module Server

    def self.included(base)
      base.class_eval {

        get "/bus" do
          erb File.read(File.join(File.dirname(__FILE__), "server/views/bus.erb"))
        end
        
        
        post '/bus/unsubscribe' do
          app = ::QueueBus::Application.new(params[:name]).unsubscribe
          redirect u('bus')
        end
        
      }
    end
  end
end

::Resque::Server.tabs << 'Bus'
::Resque::Server.class_eval do
  include ::ResqueBus::Server
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
resque-bus-0.7.0	lib/resque_bus/server.rb
resque-bus-0.6.1	lib/resque_bus/server.rb
resque-bus-0.6.0	lib/resque_bus/server.rb
resque-bus-0.5.12	lib/resque_bus/server.rb
resque-bus-0.5.11	lib/resque_bus/server.rb
resque-bus-0.5.10	lib/resque_bus/server.rb
resque-bus-0.5.9	lib/resque_bus/server.rb