You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2015/01/29 12:35:44 UTC

svn commit: r1655597 - /qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/SelectorThread.java

Author: rgodfrey
Date: Thu Jan 29 11:35:44 2015
New Revision: 1655597

URL: http://svn.apache.org/r1655597
Log:
Fix selector leak

Modified:
    qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/SelectorThread.java

Modified: qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/SelectorThread.java
URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/SelectorThread.java?rev=1655597&r1=1655596&r2=1655597&view=diff
==============================================================================
--- qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/SelectorThread.java (original)
+++ qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/SelectorThread.java Thu Jan 29 11:35:44 2015
@@ -45,16 +45,7 @@ public class SelectorThread extends Thre
 
     SelectorThread(final String name)
     {
-
         super("SelectorThread-"+name);
-        try
-        {
-            _selector = Selector.open();
-        }
-        catch (IOException e)
-        {
-            throw new RuntimeException("Failed to create selector");
-        }
     }
 
     @Override



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org