Skip to content

Commit

Permalink
Fix enqueuing
Browse files Browse the repository at this point in the history
  • Loading branch information
rwdaigle committed May 23, 2011
1 parent 6457c47 commit 0fce195
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion Procfile
@@ -1,4 +1,4 @@
web: bundle exec thin start -p $PORT -e $RACK_ENV
stream: bundle exec rake tweetstream:stream --trace
worker: bundle exec rake resque:work QUEUE=normal VERBOSE=1 --trace
worker: bundle exec rake resque:work QUEUE=normal --trace
clock: bundle exec clockwork clock.rb
4 changes: 2 additions & 2 deletions Rakefile
Expand Up @@ -6,9 +6,9 @@ require "tweetstream"
require "resque"
require 'resque/tasks'

STDOUT.sync = true
require File.dirname(__FILE__) + "/jobs/index_tweet"

Pusher.app_id = 5700
STDOUT.sync = true

task "tweetstream:stream" do
TweetStream::Client.new(ENV["TWITTER_USERNAME"], ENV["TWITTER_PASSWORD"]).track(ENV["TWITTER_KEYWORD"]) do |status|
Expand Down
2 changes: 1 addition & 1 deletion jobs/index_tweets.rb → jobs/index_tweet.rb
Expand Up @@ -3,7 +3,7 @@ class IndexTweet
@queue = :normal

def self.perform(tweet)
puts "Indexing: #{tweet}"
puts "Indexing: #{tweet["text"]}"
end

end

0 comments on commit 0fce195

Please sign in to comment.