out: define method to use chunk#msgpack_each for v0.14

groonga · Apr 11, 2017 · ddf4921 · ddf4921
1 parent b35d36f
commit ddf4921
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/fluent/plugin/out_groonga.rb b/lib/fluent/plugin/out_groonga.rb
@@ -112,6 +112,10 @@ def format(tag, time, record)
         [tag, time, record].to_msgpack
       end
 
+      def formatted_to_msgpack_binary
+        true
+      end
+
       def write(chunk)
         @emitter.emit(chunk)
       end