lib/pakyow/realtime/server/adapters/redis.rb in pakyow-realtime-1.0.0.rc5 vs lib/pakyow/realtime/server/adapters/redis.rb in pakyow-realtime-1.0.0

- old
+ new

@@ -167,11 +167,13 @@ [@prefix, PUBSUB_PREFIX].join(KEY_PART_SEPARATOR) end def cleanup Concurrent::TimerTask.new(execution_interval: 300, timeout_interval: 300) { - Pakyow.logger.debug "[Pakyow::Realtime::Server::Adapters::Redis] Cleaning up channel keys" + Pakyow.logger.internal { + "[Pakyow::Realtime::Server::Adapters::Redis] Cleaning up channel keys" + } removed_count = 0 @redis.with do |redis| redis.scan_each(match: key_socket_ids_by_channel("*")) do |key| socket_ids = redis.zrangebyscore( @@ -183,10 +185,12 @@ redis.del(key) end end end - Pakyow.logger.debug "[Pakyow::Realtime::Server::Adapters::Redis] Removed #{removed_count} keys" + Pakyow.logger.internal { + "[Pakyow::Realtime::Server::Adapters::Redis] Removed #{removed_count} keys" + } }.execute end class Buffer # The number of publish commands to pipeline to redis.