module Pubsubstub
Constants
- VERSION
Attributes
Public Class Methods
Source
# File lib/pubsubstub.rb, line 56 def handle_error(error) logger.error("Uncaught exception: #{error.class}: #{error.message}\n#{error.backtrace.join("\n\t")}\n") error_handler && error_handler.call(error) end
Source
# File lib/pubsubstub.rb, line 52 def heartbeat_event Event.new('ping', name: 'heartbeat', retry_after: reconnect_timeout) end
Source
# File lib/pubsubstub.rb, line 26 def publish(channel_name, *args) Channel.new(channel_name).publish(Event.new(*args)) nil end
Source
# File lib/pubsubstub.rb, line 36 def redis @redis || @mutex.synchronize { @redis ||= new_redis } end
Source
# File lib/pubsubstub.rb, line 40 def redis=(client) @mutex.synchronize { @redis = client } end
Source
# File lib/pubsubstub.rb, line 31 def redis_url=(url) @redis_url = url.to_s @redis = nil end
Source
# File lib/pubsubstub.rb, line 61 def report_errors yield rescue => error handle_error(error) raise end
Source
# File lib/pubsubstub.rb, line 48 def subscriber @subscriber || @mutex.synchronize { @subscriber ||= Subscriber.new } end