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