queue jobs with minion and rabbitmq

app/controllers/feeds_controller.rb

@@ -16,7 +16,7 @@ def show
   end
 
   def create
-    feed = Feed.create! :url => params[:url]
+    Feed.enqueue(params[:url])
     redirect_to :action => :index
   end
 

app/models/feed.rb

@@ -3,8 +3,12 @@ class Feed < ActiveRecord::Base
 
   after_create :fetch
 
+  def self.enqueue(url)
+    Minion.enqueue('feed.fetch', :url => url)
+  end
+
   def fetch
-    Delayed::Job.enqueue self
+    self.class.enqueue(url)
   end
 
   def perform
@@ -28,4 +32,8 @@ def self.fetch_all
       feed.fetch
     end
   end
+
+  def self.find_or_new(url)
+    find_by_url(url) || Feed.new(:url => url)
+  end
 end

db/schema.rb

@@ -9,20 +9,7 @@
 #
 # It's strongly recommended to check this file into your version control system.
 
-ActiveRecord::Schema.define(:version => 20090412203342) do
-
-  create_table "delayed_jobs", :force => true do |t|
-    t.integer  "priority",   :default => 0
-    t.integer  "attempts",   :default => 0
-    t.text     "handler"
-    t.string   "last_error"
-    t.datetime "run_at"
-    t.datetime "locked_at"
-    t.datetime "failed_at"
-    t.string   "locked_by"
-    t.datetime "created_at"
-    t.datetime "updated_at"
-  end
+ActiveRecord::Schema.define(:version => 20090411033334) do
 
   create_table "feeds", :force => true do |t|
     t.string   "url"

worker.rb

@@ -0,0 +1,9 @@
+require File.dirname(__FILE__) + '/config/environment'
+
+include Minion
+
+job 'feed.fetch' do |args|
+  feed = Feed.find_or_new(args['url'])
+  feed.perform
+end
+