Class: LogStash::Outputs::HipChat
- Inherits:
-
Base
- Object
- Base
- LogStash::Outputs::HipChat
- Defined in:
- lib/logstash/outputs/hipchat.rb
Overview
This output allows you to write events to www.hipchat.com/[HipChat].
Instance Method Summary collapse
-
#encode(hash) ⇒ Object
shamelessly lifted this from the LogStash::Outputs::Http, I’d rather put this in a common place for both to use, but unsure where that place is or should be.
- #receive(event) ⇒ Object
- #register ⇒ Object
Instance Method Details
#encode(hash) ⇒ Object
shamelessly lifted this from the LogStash::Outputs::Http, I’d rather put this in a common place for both to use, but unsure where that place is or should be
73 74 75 76 77 |
# File 'lib/logstash/outputs/hipchat.rb', line 73 def encode(hash) return hash.collect do |key, value| CGI.escape(key) + "=" + CGI.escape(value) end.join("&") end |
#receive(event) ⇒ Object
43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 |
# File 'lib/logstash/outputs/hipchat.rb', line 43 def receive(event) return unless output?(event) hipchat_data = Hash.new hipchat_data['room_id'] = event.sprintf(@room_id) hipchat_data['from'] = @from hipchat_data['color'] = @color hipchat_data['notify'] = @trigger_notify ? "1" : "0" hipchat_data['message'] = event.sprintf(@format) @logger.debug("HipChat data", :hipchat_data => hipchat_data) begin request = @agent.post(@url) request["Content-Type"] = @content_type request.body = encode(hipchat_data) response = @agent.execute(request) # Consume body to let this connection be reused rbody = "" response.read_body { |c| rbody << c } #puts rbody rescue Exception => e @logger.warn("Unhandled exception", :request => request, :response => response, :exception => e, :stacktrace => e.backtrace) end end |
#register ⇒ Object
32 33 34 35 36 37 38 39 40 |
# File 'lib/logstash/outputs/hipchat.rb', line 32 def register require "ftw" require "uri" @agent = FTW::Agent.new @url = "https://api.hipchat.com/v1/rooms/message?auth_token=" + @token @content_type = "application/x-www-form-urlencoded" end |