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();