Web socket input issue with certstream

[Alfalab]

hi,

here is a tail of log

[2020-03-24T10:41:35,144][WARN ][logstash.inputs.websocket][main] websocket input client threw exception, restarting {:exception=>#<NoMethodError: undefined method `each' for #FTW::Response:0x4b712701>}

[2020-03-24T10:41:36,178][WARN ][logstash.inputs.websocket][main] websocket input client threw exception, restarting {:exception=>#<NoMethodError: undefined method `each' for #FTW::Response:0x7dc0bc54>}

[2020-03-24T10:41:37,212][WARN ][logstash.inputs.websocket][main] websocket input client threw exception, restarting {:exception=>#<NoMethodError: undefined method `each' for #FTW::Response:0x688030e2>}

[2020-03-24T10:41:38,247][WARN ][logstash.inputs.websocket][main] websocket input client threw exception, restarting {:exception=>#<NoMethodError: undefined method `each' for #FTW::Response:0x6d22c787>}

[2020-03-24T10:41:39,276][WARN ][logstash.inputs.websocket][main] websocket input client threw exception, restarting {:exception=>#<NoMethodError: undefined method `each' for #FTW::Response:0x54c89997>}

here is the input part of config:

input {

websocket {

#id => "CertStream"

url => "ws://certstream.calidog.io/?param=Logstash"

type => "plain"

mode => "client"

codec => "json"

}

[Badger]

That looks similar to this issue, although the current version of the code does test whether it has an FTW::WebSocket or an FTW::Response before calling .each, so I would not expect the current code to hit this.

[Alfalab]

Thank you !!!