diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2009-01-13 18:54:38 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2009-01-13 18:54:38 +0000 |
| commit | 23ac63080d7337781f8dc24ee9391e85bf0c3a3d (patch) | |
| tree | 9f73429726fadddfe2b61205ba920806bb3d7891 /qpid/java | |
| parent | 4a99f7e457287fb17543be95f26d9b8ae4039a80 (diff) | |
| download | qpid-python-23ac63080d7337781f8dc24ee9391e85bf0c3a3d.tar.gz | |
This is related QPID-1479
This commit contains the modifications for using the thread abstraction within MINA.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@734214 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/transport/QpidThreadExecutor.java | 22 | ||||
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java | 6 |
2 files changed, 25 insertions, 3 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/transport/QpidThreadExecutor.java b/qpid/java/client/src/main/java/org/apache/qpid/client/transport/QpidThreadExecutor.java new file mode 100644 index 0000000000..3de410fb69 --- /dev/null +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/transport/QpidThreadExecutor.java @@ -0,0 +1,22 @@ +package org.apache.qpid.client.transport; + +import org.apache.qpid.thread.Threading; + +import edu.emory.mathcs.backport.java.util.concurrent.Executor; + +public class QpidThreadExecutor implements Executor +{ + @Override + public void execute(Runnable command) + { + try + { + Threading.getThreadFactory().createThread(command).start(); + } + catch(Exception e) + { + throw new RuntimeException("Error creating a thread using Qpid thread factory",e); + } + } + +} diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java b/qpid/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java index 6c12821c74..0bacda04ff 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/transport/TransportConnection.java @@ -91,7 +91,7 @@ public class TransportConnection { public IoConnector newSocketConnector() { - return new ExistingSocketConnector(); + return new ExistingSocketConnector(1,new QpidThreadExecutor()); } }); case TCP: @@ -106,12 +106,12 @@ public class TransportConnection _logger.warn("Using Qpid MultiThreaded NIO - " + (System.getProperties().containsKey("qpidnio") ? "Qpid NIO is new default" : "Sysproperty 'qpidnio' is set")); - result = new MultiThreadSocketConnector(); + result = new MultiThreadSocketConnector(1, new QpidThreadExecutor()); } else { _logger.info("Using Mina NIO"); - result = new SocketConnector(); // non-blocking connector + result = new SocketConnector(1, new QpidThreadExecutor()); // non-blocking connector } // Don't have the connector's worker thread wait around for other connections (we only use // one SocketConnector per connection at the moment anyway). This allows short-running |