From b7cfff9be6ece4cd2e239d059ab1e3ccbbd5e2d0 Mon Sep 17 00:00:00 2001 From: Masahiro Nakagawa Date: Wed, 16 Dec 2015 16:26:09 +0900 Subject: [PATCH 1/2] Engine requires fluent/time.rb for EventTime --- lib/fluent/engine.rb | 1 + 1 file changed, 1 insertion(+) diff --git a/lib/fluent/engine.rb b/lib/fluent/engine.rb index 6952495478..05883ffbe4 100644 --- a/lib/fluent/engine.rb +++ b/lib/fluent/engine.rb @@ -17,6 +17,7 @@ module Fluent require 'fluent/event_router' require 'fluent/root_agent' + require 'fluent/time' class EngineClass def initialize From 37cd84099a621afc32d710e2dde7c454ac97d2e3 Mon Sep 17 00:00:00 2001 From: Masahiro Nakagawa Date: Wed, 16 Dec 2015 16:28:21 +0900 Subject: [PATCH 2/2] fluent-cat requires fluent/engine with --msgpack option. fix #746 --- lib/fluent/command/cat.rb | 2 ++ 1 file changed, 2 insertions(+) diff --git a/lib/fluent/command/cat.rb b/lib/fluent/command/cat.rb index 49f4aaa469..8ec8a5e2c1 100644 --- a/lib/fluent/command/cat.rb +++ b/lib/fluent/command/cat.rb @@ -288,6 +288,8 @@ def abort_message(time, record) end when 'msgpack' + require 'fluent/engine' + begin u = Fluent::Engine.msgpack_factory.unpacker($stdin) u.each {|record|