[jboss-remoting-commits] JBoss Remoting SVN: r3454 - remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core.

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

Author: david.lloyd at jboss.com
Date: 2008-02-18 21:39:22 -0500 (Mon, 18 Feb 2008)
New Revision: 3454

Removed:
   remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/ThreadPoolInterceptor.java
Log:
Remove useless interceptor implementation

Deleted: remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/ThreadPoolInterceptor.java
===================================================================
--- remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/ThreadPoolInterceptor.java	2008-02-19 02:38:59 UTC (rev 3453)
+++ remoting3/trunk/core/src/main/java/org/jboss/cx/remoting/core/ThreadPoolInterceptor.java	2008-02-19 02:39:22 UTC (rev 3454)
@@ -1,68 +0,0 @@
-package org.jboss.cx.remoting.core;
-
-import java.util.concurrent.ArrayBlockingQueue;
-import java.util.concurrent.ConcurrentMap;
-import java.util.concurrent.Future;
-import java.util.concurrent.FutureTask;
-import java.util.concurrent.RejectedExecutionException;
-import java.util.concurrent.ThreadPoolExecutor;
-import org.jboss.cx.remoting.RemoteExecutionException;
-import org.jboss.cx.remoting.core.util.CollectionUtil;
-import org.jboss.cx.remoting.log.Logger;
-import org.jboss.cx.remoting.spi.AbstractServerInterceptor;
-import org.jboss.cx.remoting.spi.InterceptorContext;
-import org.jboss.cx.remoting.spi.protocol.RequestIdentifier;
-
-/**
- *
- */
-public final class ThreadPoolInterceptor extends AbstractServerInterceptor {
-    private static final ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(30, 50, 0, null, new ArrayBlockingQueue<Runnable>(100, true));
-    private final ConcurrentMap<RequestIdentifier, Future<Void>> requests = CollectionUtil.concurrentWeakHashMap();
-
-    private static final Logger log = Logger.getLogger(ThreadPoolInterceptor.class);
-
-    public void processInboundCancelRequest(final InterceptorContext context, final RequestIdentifier requestIdentifier, final boolean mayInterruptIfRunning) {
-        try {
-            super.processInboundCancelRequest(context, requestIdentifier, false);
-        } finally {
-            final Future<Void> future = requests.get(requestIdentifier);
-            if (future != null) {
-                if (future.cancel(mayInterruptIfRunning)) {
-
-                }
-            }
-        }
-    }
-
-    public void processInboundRequest(final InterceptorContext context, final RequestIdentifier requestIdentifier, final Object request) {
-        try {
-            // Use FutureTask so that we get a Future<> before the task actually starts
-            FutureTask<Void> task = new FutureTask<Void>(new Runnable() {
-                public void run() {
-                    ThreadPoolInterceptor.super.processInboundRequest(context, requestIdentifier, request);
-                }
-            }, null);
-            requests.put(requestIdentifier, task);
-            threadPoolExecutor.execute(task);
-        } catch (RejectedExecutionException e) {
-            processOutboundException(context, requestIdentifier, new RemoteExecutionException("Request job submission rejected (the server may be too busy to service this request)", e));
-        }
-    }
-
-    public void processOutboundCancelAcknowledge(final InterceptorContext context, final RequestIdentifier requestIdentifier) {
-        requests.remove(requestIdentifier);
-        super.processOutboundCancelAcknowledge(context, requestIdentifier);
-    }
-
-    public void processOutboundReply(final InterceptorContext context, final RequestIdentifier requestIdentifier, final Object reply) {
-        requests.remove(requestIdentifier);
-        super.processOutboundReply(context, requestIdentifier, reply);
-    }
-
-    public void processOutboundException(final InterceptorContext context, final RequestIdentifier requestIdentifier, final RemoteExecutionException exception) {
-        requests.remove(requestIdentifier);
-        super.processOutboundException(context, requestIdentifier, exception);
-    }
-
-}