github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-25 07:07:54 -04:00
Code Issues Projects Releases Packages Wiki Activity

read response body

Browse source
This commit is contained in:
Jordan Sissel 2012-12-06 02:02:32 -08:00
parent 63ef8b4f36
commit a52677946b
1 changed files with 9 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

14
lib/logstash/outputs/http.rb
View file

@ -101,12 +101,16 @@ class LogStash::Outputs::Http < LogStash::Outputs::Base
else else
request.body = encode(evt) request.body = encode(evt)
end end
puts request #puts "#{request.port} / #{request.protocol}"
puts #puts request
puts request.body #puts
#puts request.body
response = @agent.execute(request) response = @agent.execute(request)
puts response
response.read_body { |c| puts c } # Consume body to let this connection be reused
rbody = ""
response.read_body { |c| rbody << c }
#puts rbody
rescue Exception => e rescue Exception => e
@logger.warn("Unhandled exception", :request => request, :response => response, :exception => e, :stacktrace => e.backtrace) @logger.warn("Unhandled exception", :request => request, :response => response, :exception => e, :stacktrace => e.backtrace)
end end