Sha256: e9da3193cbbf2ea2a0b798fc82abc9fb08e33d0ac71a455dcc18412848364e69
Contents?: true
Size: 1.47 KB
Versions: 9
Compression:
Stored size: 1.47 KB
Contents
# encoding: utf-8
require "logstash-input-http_jars"
java_import org.logstash.plugins.inputs.http.MessageHandler
java_import "io.netty.handler.codec.http.DefaultFullHttpResponse"
java_import "io.netty.handler.codec.http.HttpHeaderNames"
java_import "io.netty.handler.codec.http.HttpVersion"
java_import "io.netty.handler.codec.http.HttpResponseStatus"
java_import "io.netty.buffer.Unpooled"
java_import "io.netty.util.CharsetUtil"
module LogStash module Inputs class Http
class MessageHandler
include org.logstash.plugins.inputs.http.IMessageHandler
attr_reader :input
def initialize(input, default_codec, additional_codecs, auth_token)
@input = input
@default_codec = default_codec
@additional_codecs = additional_codecs
@auth_token = auth_token
end
def validates_token(token)
if @auth_token
@auth_token == token
else
true
end
end
def onNewMessage(remote_address, headers, body)
@input.decode_body(headers, remote_address, body, @default_codec, @additional_codecs)
end
def copy
MessageHandler.new(@input, @default_codec.clone, clone_additional_codecs(), @auth_token)
end
def clone_additional_codecs
clone_additional_codecs = {}
@additional_codecs.each do |content_type, codec|
clone_additional_codecs[content_type] = codec.clone
end
clone_additional_codecs
end
def response_headers
@input.response_headers
end
end
end; end; end
Version data entries
9 entries across 9 versions & 1 rubygems