[jboss-remoting-commits] JBoss Remoting SVN: r4711 - remoting3/trunk/standalone/src/main/java/org/jboss/remoting.

[jboss-remoting-commits at lists.jboss.org]

Author: david.lloyd at jboss.com
Date: 2008-11-19 15:07:11 -0500 (Wed, 19 Nov 2008)
New Revision: 4711

Modified:
   remoting3/trunk/standalone/src/main/java/org/jboss/remoting/Remoting.java
Log:
I always make this mistake :)

Modified: remoting3/trunk/standalone/src/main/java/org/jboss/remoting/Remoting.java
===================================================================
--- remoting3/trunk/standalone/src/main/java/org/jboss/remoting/Remoting.java	2008-11-19 19:32:02 UTC (rev 4710)
+++ remoting3/trunk/standalone/src/main/java/org/jboss/remoting/Remoting.java	2008-11-19 20:07:11 UTC (rev 4711)
@@ -61,14 +61,14 @@
         }
     }
 
-    private static class AlwaysBlockingQueue<T> implements BlockingQueue<T> {
-        private final BlockingQueue<T> delegate;
+    private static class AlwaysBlockingQueue<E> implements BlockingQueue<E> {
+        private final BlockingQueue<E> delegate;
 
-        public AlwaysBlockingQueue(final BlockingQueue<T> delegate) {
+        public AlwaysBlockingQueue(final BlockingQueue<E> delegate) {
             this.delegate = delegate;
         }
 
-        public boolean offer(final T o) {
+        public boolean offer(final E o) {
             try {
                 delegate.put(o);
                 return true;
@@ -78,19 +78,19 @@
             }
         }
 
-        public boolean offer(final T o, final long timeout, final TimeUnit unit) throws InterruptedException {
+        public boolean offer(final E o, final long timeout, final TimeUnit unit) throws InterruptedException {
             return delegate.offer(o, timeout, unit);
         }
 
-        public T poll(final long timeout, final TimeUnit unit) throws InterruptedException {
+        public E poll(final long timeout, final TimeUnit unit) throws InterruptedException {
             return delegate.poll(timeout, unit);
         }
 
-        public T take() throws InterruptedException {
+        public E take() throws InterruptedException {
             return delegate.take();
         }
 
-        public void put(final T o) throws InterruptedException {
+        public void put(final E o) throws InterruptedException {
             delegate.put(o);
         }
 
@@ -98,31 +98,31 @@
             return delegate.remainingCapacity();
         }
 
-        public boolean add(final T o) {
+        public boolean add(final E o) {
             return delegate.add(o);
         }
 
-        public int drainTo(final Collection<? super T> c) {
+        public int drainTo(final Collection<? super E> c) {
             return delegate.drainTo(c);
         }
 
-        public int drainTo(final Collection<? super T> c, final int maxElements) {
+        public int drainTo(final Collection<? super E> c, final int maxElements) {
             return delegate.drainTo(c, maxElements);
         }
 
-        public T poll() {
+        public E poll() {
             return delegate.poll();
         }
 
-        public T remove() {
+        public E remove() {
             return delegate.remove();
         }
 
-        public T peek() {
+        public E peek() {
             return delegate.peek();
         }
 
-        public T element() {
+        public E element() {
             return delegate.element();
         }
 
@@ -138,7 +138,7 @@
             return delegate.contains(o);
         }
 
-        public Iterator<T> iterator() {
+        public Iterator<E> iterator() {
             return delegate.iterator();
         }
 
@@ -147,6 +147,7 @@
         }
 
         public <T> T[] toArray(final T[] a) {
+            //noinspection SuspiciousToArrayCall
             return delegate.toArray(a);
         }
 
@@ -158,7 +159,7 @@
             return delegate.containsAll(c);
         }
 
-        public boolean addAll(final Collection<? extends T> c) {
+        public boolean addAll(final Collection<? extends E> c) {
             return delegate.addAll(c);
         }