You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@directory.apache.org by el...@apache.org on 2007/08/23 03:56:41 UTC
svn commit: r568803 -
/directory/apacheds/trunk/protocol-dns/src/main/java/org/apache/directory/server/dns/Main.java
Author: elecharny
Date: Wed Aug 22 18:56:41 2007
New Revision: 568803
URL: http://svn.apache.org/viewvc?rev=568803&view=rev
Log:
Modified the code to be compatible with MINA 1.1.2
Modified:
directory/apacheds/trunk/protocol-dns/src/main/java/org/apache/directory/server/dns/Main.java
Modified: directory/apacheds/trunk/protocol-dns/src/main/java/org/apache/directory/server/dns/Main.java
URL: http://svn.apache.org/viewvc/directory/apacheds/trunk/protocol-dns/src/main/java/org/apache/directory/server/dns/Main.java?rev=568803&r1=568802&r2=568803&view=diff
==============================================================================
--- directory/apacheds/trunk/protocol-dns/src/main/java/org/apache/directory/server/dns/Main.java (original)
+++ directory/apacheds/trunk/protocol-dns/src/main/java/org/apache/directory/server/dns/Main.java Wed Aug 22 18:56:41 2007
@@ -20,6 +20,10 @@
package org.apache.directory.server.dns;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
import org.apache.directory.server.dns.store.RecordStore;
import org.apache.directory.server.dns.store.RecordStoreStub;
import org.apache.mina.common.ExecutorThreadModel;
@@ -30,10 +34,6 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import edu.emory.mathcs.backport.java.util.concurrent.LinkedBlockingQueue;
-import edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor;
-import edu.emory.mathcs.backport.java.util.concurrent.TimeUnit;
-
/**
* @author <a href="mailto:dev@directory.apache.org">Apache Directory Project</a>
@@ -65,7 +65,7 @@
{
int maxThreads = MAX_THREADS_DEFAULT;
threadPoolExecutor = new ThreadPoolExecutor( maxThreads, maxThreads, 60, TimeUnit.SECONDS,
- new LinkedBlockingQueue() );
+ new LinkedBlockingQueue<Runnable>() );
threadModel.setExecutor( threadPoolExecutor );
udpAcceptor = new DatagramAcceptor();