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.