Refactoring: Remove unnecessary conditions

All chunk classes which inherit Chunk have enqueued! method.
fluent · Oct 16, 2017 · e845897 · e845897
1 parent 86eaa2c
commit e845897
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/fluent/plugin/buffer.rb b/lib/fluent/plugin/buffer.rb
@@ -323,7 +323,7 @@ def enqueue_chunk(metadata)
             else
               @queue << chunk
               @queued_num[metadata] = @queued_num.fetch(metadata, 0) + 1
-              chunk.enqueued! if chunk.respond_to?(:enqueued!)
+              chunk.enqueued!
             end
           end
           bytesize = chunk.bytesize
@@ -340,7 +340,7 @@ def enqueue_unstaged_chunk(chunk)
             metadata = chunk.metadata
             @queue << chunk
             @queued_num[metadata] = @queued_num.fetch(metadata, 0) + 1
-            chunk.enqueued! if chunk.respond_to?(:enqueued!)
+            chunk.enqueued!
           end
           @queue_size += chunk.bytesize
         end