lib/magent_web/app.rb in magent-0.6.0 vs lib/magent_web/app.rb in magent-0.6.1

@@ -39,18 +39,23 @@
       haml :"queues/failed"
     end
 
     get "/queues/:id/stats" do
       @queue = @database.collection(params[:id])
+      @channel_name = channel_name_for(params[:id])
+      channel = Magent::GenericChannel.new(@channel_name)
 
+      @stats_collection = channel.stats_collection
+      @stats = channel.stats
+
       haml :"queues/stats"
     end
 
     get "/queues/:queue_id/retry/:id" do
       @errors_queue = @database.collection(params[:queue_id]+".errors")
       @channel_name = channel_name_for(params[:queue_id])
 
-      channel = Magent::AsyncChannel.new(@channel_name)
+      channel = Magent::GenericChannel.new(@channel_name)
 
       doc = @errors_queue.find({:_id => params[:id]}).next_document
       channel.enqueue_error(doc)
 
       redirect "/queues/#{params[:queue_id]}/failed"