Commit b88a5bb6 authored by Gaston Dombiak's avatar Gaston Dombiak Committed by gato

Ensure that packets are never lost even if thread pool is exhausted. JM-491

git-svn-id: http://svn.igniterealtime.org/svn/repos/messenger/trunk@3192 b35dd754-fafc-0310-a699-88a17e54d16e
parent 3a538417
...@@ -71,7 +71,7 @@ public class OutgoingSessionPromise implements RoutableChannelHandler { ...@@ -71,7 +71,7 @@ public class OutgoingSessionPromise implements RoutableChannelHandler {
threadPool = threadPool =
new ThreadPoolExecutor(Math.round(maxThreads/4), maxThreads, 60, TimeUnit.SECONDS, new ThreadPoolExecutor(Math.round(maxThreads/4), maxThreads, 60, TimeUnit.SECONDS,
new LinkedBlockingQueue<Runnable>(), new LinkedBlockingQueue<Runnable>(),
new ThreadPoolExecutor.AbortPolicy()); new ThreadPoolExecutor.DiscardOldestPolicy());
// Start the thread that will consume the queued packets. Each pending packet will // Start the thread that will consume the queued packets. Each pending packet will
// be actually processed by a thread of the pool (when available). If an error occurs // be actually processed by a thread of the pool (when available). If an error occurs
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment