aboutsummaryrefslogtreecommitdiff
path: root/logstash-core/src/main/java/org/logstash/ext/JrubyMemoryReadClientExt.java
diff options
context:
space:
mode:
Diffstat (limited to 'logstash-core/src/main/java/org/logstash/ext/JrubyMemoryReadClientExt.java')
-rw-r--r--logstash-core/src/main/java/org/logstash/ext/JrubyMemoryReadClientExt.java8
1 files changed, 3 insertions, 5 deletions
diff --git a/logstash-core/src/main/java/org/logstash/ext/JrubyMemoryReadClientExt.java b/logstash-core/src/main/java/org/logstash/ext/JrubyMemoryReadClientExt.java
index 2dba2253..822ba8a2 100644
--- a/logstash-core/src/main/java/org/logstash/ext/JrubyMemoryReadClientExt.java
+++ b/logstash-core/src/main/java/org/logstash/ext/JrubyMemoryReadClientExt.java
@@ -1,5 +1,7 @@
package org.logstash.ext;
+import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.TimeUnit;
import org.jruby.Ruby;
import org.jruby.RubyClass;
import org.jruby.anno.JRubyClass;
@@ -7,14 +9,10 @@ import org.logstash.RubyUtil;
import org.logstash.common.LsQueueUtils;
import org.logstash.execution.MemoryReadBatch;
import org.logstash.execution.QueueBatch;
-import org.logstash.execution.QueueReadClient;
import org.logstash.execution.QueueReadClientBase;
-import java.util.concurrent.BlockingQueue;
-import java.util.concurrent.TimeUnit;
-
@JRubyClass(name = "MemoryReadClient", parent = "QueueReadClientBase")
-public final class JrubyMemoryReadClientExt extends QueueReadClientBase implements QueueReadClient {
+public final class JrubyMemoryReadClientExt extends QueueReadClientBase {
private BlockingQueue queue;