Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP

Loading…

block redis output when redis is down #198

Merged
merged 1 commit into from

2 participants

@alexdean

retrying until we succeed will block filters & inputs, preventing too many
messages from accumulating in the redis output.

@alexdean alexdean retry failed flushes to redis
retrying until we succeed will block filters & inputs, preventing too many
messages from accumulating in the redis output.
6ed24ad
@jordansissel jordansissel merged commit aea7a7b into from
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Commits on Sep 6, 2012
  1. @alexdean

    retry failed flushes to redis

    alexdean authored
    retrying until we succeed will block filters & inputs, preventing too many
    messages from accumulating in the redis output.
This page is out of date. Refresh to see the latest.
Showing with 4 additions and 1 deletion.
  1. +4 −1 lib/logstash/outputs/redis.rb
View
5 lib/logstash/outputs/redis.rb
@@ -143,7 +143,8 @@ def receive(event)
@logger.warn("Failed to send event to redis", :event => event,
:identity => identity, :exception => e,
:backtrace => e.backtrace)
- raise e
+ sleep 1
+ retry
end
end # def receive
@@ -178,6 +179,8 @@ def process_pending(force=false)
:pending_count => pending_count,
:identity => identity, :exception => e,
:backtrace => e.backtrace)
+ sleep 1
+ retry
end
end
Something went wrong with that request. Please try again.