Skip to content

Commit

Permalink
edit readme
Browse files Browse the repository at this point in the history
  • Loading branch information
Sam committed May 30, 2012
1 parent bffce6d commit ac6c694
Show file tree
Hide file tree
Showing 3 changed files with 28 additions and 28 deletions.
Binary file removed .DS_Store
Binary file not shown.
2 changes: 1 addition & 1 deletion .gitignore
@@ -1,4 +1,4 @@
.DS_Store
.DS_Store
*.gem
*.rbc
.bundle
Expand Down
54 changes: 27 additions & 27 deletions README.md
Expand Up @@ -20,41 +20,41 @@ Or install it yourself as:

### In your application use Redis Device

require 'logger'
require 'redis_logger_device'
dev = RedisLoggerDevice::Base.new
logger = Logger.new(dev)
logger.info("AAAAAaaaaaahhhhh")
logger.close
require 'logger'
require 'redis_logger_device'
dev = RedisLoggerDevice::Base.new
logger = Logger.new(dev)
logger.info("AAAAAaaaaaahhhhh")
logger.close

---

### Make your Logger Worker in background for process log entries

require 'logger'
require 'redis_logger_device'
include RedisLoggerDevice
class SimpleLogWorker < LogWorker
def process_queue!
loop do
begin
@logger.info("LogWorker fetching (#{@queue_name})...")
key, val = @redis.brpop @queue_name
@logger.info("LogWorker rocess key: #{key}; val: #{val}")
#your code : val = log entry
rescue SignalException => e
raise e
rescue Exception => e
@logger.fatal "LogWorker error: #{e.message}"
raise e
require 'logger'
require 'redis_logger_device'
include RedisLoggerDevice
class SimpleLogWorker < LogWorker
def process_queue!
loop do
begin
@logger.info("LogWorker fetching (#{@queue_name})...")
key, val = @redis.brpop @queue_name
@logger.info("LogWorker rocess key: #{key}; val: #{val}")
#your code : val = log entry
rescue SignalException => e
raise e
rescue Exception => e
@logger.fatal "LogWorker error: #{e.message}"
raise e
end
end
end
end
end
worker_logger = Logger.new(STDOUT)
worker = SimpleLogWorker.new(worker_logger)
worker.process_queue!
worker_looger.close
worker_logger = Logger.new(STDOUT)
worker = SimpleLogWorker.new(worker_logger)
worker.process_queue!
worker_looger.close

## Contributing

Expand Down

0 comments on commit ac6c694

Please sign in to comment.