Redis + ActionController::Live threads not dying

by

A solution I just did (borrowing a lot from @teeg) which seems to work okay (haven’t failure tested it, tho)

config/initializers/redis.rb

$redis = Redis.new(:host => "xxxx.com", :port => 6379)

heartbeat_thread = Thread.new do
  while true
    $redis.publish("heartbeat","thump")
    sleep 30.seconds
  end
end

at_exit do
  # not sure this is needed, but just in case
  heartbeat_thread.kill
  $redis.quit
end

And then in my controller:

def events
    response.headers["Content-Type"] = "text/event-stream"
    redis = Redis.new(:host => "xxxxxxx.com", :port => 6379)
    logger.info "New stream starting, connecting to redis"
    redis.subscribe(['parse.new','heartbeat']) do |on|
      on.message do |event, data|
        if event == 'parse.new'
          response.stream.write("event: parse\ndata: #{data}\n\n")
        elsif event == 'heartbeat'
          response.stream.write("event: heartbeat\ndata: heartbeat\n\n")
        end
      end
    end
  rescue IOError
    logger.info "Stream closed"
  ensure
    logger.info "Stopping stream thread"
    redis.quit
    response.stream.close
  end

More Related Contents:

  1. Is puma the ONLY multi-threaded rails 4 http server?
  2. Boolean Validation
  3. How is attr_accessible used in Rails 4?
  4. Nested attributes unpermitted parameters
  5. Rails: How to reference images in CSS within Rails 4
  6. How to solve error “Missing `secret_key_base` for ‘production’ environment” (Rails 4.1)
  7. Rails 4: List of available datatypes
  8. Disable ActiveRecord for Rails 4
  9. ActiveRecord OR query Hash notation
  10. Rails association with multiple foreign keys
  11. rescue_from ActionController::RoutingError in Rails 4
  12. Rails 4: before_filter vs. before_action
  13. Saving enum from select in Rails 4.1
  14. How to configure Google Domains + Heroku w a Naked Domain
  15. Add a reference column migration in Rails 4
  16. Rails 4: organize rails models in sub path without namespacing models?
  17. Rails update_attributes without save?
  18. GroupingError: ERROR: column must appear in the GROUP BY clause or be used in an aggregate function
  19. Rails 4: assets not loading in production
  20. Rails 4 nested attributes and has_many :through associaton in a form
  21. Form Submit button only works after reload
  22. Rails I18n validation deprecation warning
  23. First argument in form cannot contain nil or be empty – Rails 4
  24. Rails 4 – Gem::LoadError: Specified ‘mysql2’ for database adapter, but the gem is not loaded
  25. Refresh token using Omniauth-oauth2 in Rails application
  26. Upgrading from Rails 2.3.8 to 4.0
  27. API Authentication for user logged in to a Web App server
  28. An error occurred while installing pg (0.17.1), and Bundler cannot continue
  29. ActionController::InvalidAuthenticityToken in RegistrationsController#create
  30. ActionController::ParameterMissing (param is missing or the value is empty: film):

Leave a Comment