File tree 1 file changed +4
-4
lines changed
1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -22,7 +22,7 @@ class LogStash::Outputs::Tcp < LogStash::Outputs::Base
22
22
# When mode is `server`, the port to listen on.
23
23
# When mode is `client`, the port to connect to.
24
24
config :port , :validate => :number , :required => true
25
-
25
+
26
26
# When connect failed,retry interval in sec.
27
27
config :reconnect_interval , :validate => :number , :default => 10
28
28
@@ -39,7 +39,7 @@ class LogStash::Outputs::Tcp < LogStash::Outputs::Base
39
39
config :message_format , :validate => :string , :deprecated => true
40
40
41
41
# respond_to? check needed for backwards compatibility with < 2.2 Logstashes
42
- declare_workers_not_supported! if self . respond_to? ( :workers_not_supported ! )
42
+ declare_workers_not_supported! if self . respond_to? ( :declare_workers_not_supported ! )
43
43
44
44
class Client
45
45
public
@@ -136,14 +136,14 @@ def server?
136
136
137
137
public
138
138
def receive ( event )
139
-
139
+
140
140
141
141
#if @message_format
142
142
#output = event.sprintf(@message_format) + "\n"
143
143
#else
144
144
#output = event.to_hash.to_json + "\n"
145
145
#end
146
-
146
+
147
147
@codec . encode ( event )
148
148
end # def receive
149
149
end # class LogStash::Outputs::Tcp
You can’t perform that action at this time.
0 commit comments