mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 06:37:19 -04:00
- remove unused exception (I think it's unused, either way we should be
retrying anyway)
This commit is contained in:
parent
e0dbee7de9
commit
d756181ac1
1 changed files with 0 additions and 3 deletions
|
@ -1,6 +1,5 @@
|
|||
require "logstash/inputs/base"
|
||||
require "logstash/namespace"
|
||||
require "timeout"
|
||||
require "socket"
|
||||
|
||||
# Read events over a 0MQ SUB socket.
|
||||
|
@ -154,8 +153,6 @@ class LogStash::Inputs::ZeroMQ < LogStash::Inputs::Base
|
|||
@logger.debug("ZMQ Error", :subscriber => @zsocket,
|
||||
:exception => e)
|
||||
retry
|
||||
rescue Timeout::Error
|
||||
@logger.debug("Read timeout", subscriber => @zsocket)
|
||||
end # begin
|
||||
end # def run
|
||||
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue