Add cusotm New Relic instrumentation

Procfile

@@ -1,3 +1,3 @@
 web: bundle exec thin start -p $PORT
-worker: bundle exec rake qc:work
+worker: bundle exec rake gisted:work
 kanshi: bundle exec kanshi

app/models/gist_fetcher.rb

@@ -2,8 +2,6 @@ class GistFetcher
 
   class << self
 
-    include ::NewRelic::Agent::Instrumentation::ControllerInstrumentation
-
     def fetch
       period = ENV['FETCH_INTERVAL_MINS'] ? ENV['FETCH_INTERVAL_MINS'].to_i : 1440
       since = period.minutes.ago
@@ -24,8 +22,6 @@ def fetch_user(user_id)
       end
       user.update_attribute(:last_gh_fetch, Time.now)
     end
-
-    add_transaction_tracer :fetch_user, :category => :task, :params => '{ :user_id => args[0] }'
 
     protected
 

app/models/gisted_worker.rb

@@ -0,0 +1,18 @@
+require "queue_classic"
+
+class GistedWorker < QC::Worker
+
+  include ::NewRelic::Agent::Instrumentation::ControllerInstrumentation
+  add_transaction_tracer :call, :category => :task, :params => '{ :job => args[0][:method], :args => args[0][:args] }'
+
+  # # retry the job
+  # def handle_failure(job, exception)
+  #   @queue.enqueue(job[:method], *job[:args])
+  # end
+
+  # # the forked proc needs a new db connection
+  # def setup_child
+  #   ActiveRecord::Base.establish_connection
+  # end
+
+end

lib/tasks/fetch.rake

@@ -1,7 +1,7 @@
 namespace :fetch do
 
   task :periodic => :environment do
-    GistFetcher.fetch
+    QC.enqueue("GistFetcher.fetch")
   end
 
 end

lib/tasks/gisted.rake

@@ -0,0 +1,6 @@
+namespace :gisted do
+
+  task :work => :environment do
+    GistedWorker.new.start
+  end
+end