svn commit: r659329 - /mina/branches/buffer/core/src/main/java/org/apache/mina/queue/ConcurrentLinkedIoQueue.java

[tr...@apache.org]

Author: trustin
Date: Thu May 22 17:24:04 2008
New Revision: 659329

URL: http://svn.apache.org/viewvc?rev=659329&view=rev
Log:
Changed ConcurrentLinkedIoQueue to extend QueueBackedIoQueue

Modified:
    mina/branches/buffer/core/src/main/java/org/apache/mina/queue/ConcurrentLinkedIoQueue.java

Modified: mina/branches/buffer/core/src/main/java/org/apache/mina/queue/ConcurrentLinkedIoQueue.java
URL: http://svn.apache.org/viewvc/mina/branches/buffer/core/src/main/java/org/apache/mina/queue/ConcurrentLinkedIoQueue.java?rev=659329&r1=659328&r2=659329&view=diff
==============================================================================
--- mina/branches/buffer/core/src/main/java/org/apache/mina/queue/ConcurrentLinkedIoQueue.java (original)
+++ mina/branches/buffer/core/src/main/java/org/apache/mina/queue/ConcurrentLinkedIoQueue.java Thu May 22 17:24:04 2008
@@ -19,8 +19,6 @@
  */
 package org.apache.mina.queue;
 
-import java.util.Iterator;
-import java.util.Queue;
 import java.util.concurrent.ConcurrentLinkedQueue;
 
 /**
@@ -32,41 +30,9 @@
  *
  * @param <E> the type of this queue's elements
  */
-public class ConcurrentLinkedIoQueue<E> extends AbstractIoQueue<E> {
+public class ConcurrentLinkedIoQueue<E> extends QueueBackedIoQueue<E> {
 
-    private final Queue<E> q = new ConcurrentLinkedQueue<E>();
-
-    public E peek() {
-        return q.peek();
-    }
-
-    @Override
-    public Iterator<E> iterator() {
-        return q.iterator();
-    }
-
-    @Override
-    public int size() {
-        return q.size();
-    }
-
-    @Override
-    public Object[] toArray() {
-        return q.toArray();
-    }
-
-    @Override
-    public <T> T[] toArray(T[] a) {
-        return q.toArray(a);
-    }
-
-    @Override
-    protected void doOffer(E e) {
-        q.offer(e);
-    }
-
-    @Override
-    protected E doPoll() {
-        return q.poll();
+    public ConcurrentLinkedIoQueue() {
+        super(new ConcurrentLinkedQueue<E>());
     }
 }