class LogStash::Outputs::Redis

Public Instance Methods

receive(event) click to toggle source
# File lib/logstash/outputs/redis.rb, line 22
def receive(event)
  @redis.rpush(event.sprintf(@queue), {
    :source_host => @hostname, 
    :source => event.source,
    :message => event.message
  }.to_json)
end
register() click to toggle source
# File lib/logstash/outputs/redis.rb, line 7
def register
  @port = nil
  @password = nil
  @host = @url.host
  _, @db, @queue = @url.path.split('/')
  require 'socket'
  @hostname = Socket.gethostname
  @work = []
  @redis = EM::Protocols::Redis.connect({
    :host => @host, 
    :port => @port, 
    :db => @db
  })
  end