We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 59a1f06 commit b2d00adCopy full SHA for b2d00ad
lib/logstash/outputs/tcp.rb
@@ -13,6 +13,7 @@
13
class LogStash::Outputs::Tcp < LogStash::Outputs::Base
14
15
config_name "tcp"
16
+ concurrency :single
17
18
default :codec, "json"
19
@@ -115,8 +116,6 @@ def register
115
116
end # @ssl_enable
117
118
if server?
- workers_not_supported
119
-
120
@logger.info("Starting tcp output listener", :address => "#{@host}:#{@port}")
121
begin
122
@server_socket = TCPServer.new(@host, @port)
0 commit comments