File tree Expand file tree Collapse file tree 1 file changed +9
-0
lines changed Expand file tree Collapse file tree 1 file changed +9
-0
lines changed Original file line number Diff line number Diff line change @@ -34,6 +34,9 @@ class LogStash::Outputs::Mongodb < LogStash::Outputs::Base
34
34
# "_id" field in the event.
35
35
config :generateId , :validate => :boolean , :default => false
36
36
37
+ # Number of insert attempts before reconnect to MongoDB
38
+ config :retries_before_reconnect , :validate => :number , :default => 3 , :required => false
39
+
37
40
38
41
# Bulk insert flag, set to true to allow bulk insertion, else it will insert events one by one.
39
42
config :bulk , :validate => :boolean , :default => false
@@ -72,6 +75,7 @@ def register
72
75
end # def register
73
76
74
77
def receive ( event )
78
+ retries = 0
75
79
begin
76
80
# Our timestamp object now has a to_bson method, using it here
77
81
# {}.merge(other) so we don't taint the event hash innards
@@ -111,6 +115,11 @@ def receive(event)
111
115
# to fix the issue.
112
116
else
113
117
sleep @retry_delay
118
+ retries += 1
119
+ if @retries_before_reconnect == retries
120
+ register
121
+ retries = 0
122
+ end
114
123
retry
115
124
end
116
125
end
You can’t perform that action at this time.
0 commit comments