module Redisse::Server::Redis
Public Instance Methods
ensure_pubsub()
click to toggle source
# File lib/redisse/server/redis.rb, line 14 def ensure_pubsub return if defined? @pubsub @pubsub = redis.pubsub @pubsub_errbacks = [] @pubsub.on(:disconnected, &method(:on_redis_close)) EM::Synchrony.sync(@pubsub) end
on_redis_close()
click to toggle source
# File lib/redisse/server/redis.rb, line 22 def on_redis_close @pubsub_errbacks.each(&:call) @pubsub_errbacks.clear end
pubsub(&on_disconnected)
click to toggle source
# File lib/redisse/server/redis.rb, line 7 def pubsub(&on_disconnected) ensure_pubsub return false unless @pubsub.connected? @pubsub_errbacks << on_disconnected true end
pubsub_subcribe(channels, callback)
click to toggle source
# File lib/redisse/server/redis.rb, line 27 def pubsub_subcribe(channels, callback) channels.each do |channel| @pubsub.subscribe(channel, callback) end end
pubsub_unsubscribe_proc(channels, callback)
click to toggle source
# File lib/redisse/server/redis.rb, line 33 def pubsub_unsubscribe_proc(channels, callback) channels.each do |channel| @pubsub.unsubscribe_proc(channel, callback) end end
redis()
click to toggle source
# File lib/redisse/server/redis.rb, line 3 def redis @redis ||= EM::Hiredis.connect(redisse.redis_server) end