summaryrefslogtreecommitdiff
path: root/java/cluster/src
diff options
context:
space:
mode:
authorRobert Greig <rgreig@apache.org>2007-01-29 16:37:13 +0000
committerRobert Greig <rgreig@apache.org>2007-01-29 16:37:13 +0000
commit45b41e212c827905f711c188457ed6cdcb97aab3 (patch)
treef9b24e181c8db1ea4c22d5b872b1fef0a3a7bddd /java/cluster/src
parent1f21d6b6a37c98886de34fb33f74e7519d2dabe6 (diff)
downloadqpid-python-45b41e212c827905f711c188457ed6cdcb97aab3.tar.gz
QPID-327 : Patch supplied by Rob Godfrey - [race condition] PoolingFilter : Possible race condition when completing a Job
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@501096 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/cluster/src')
-rw-r--r--java/cluster/src/main/java/org/apache/qpid/server/cluster/Main.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/java/cluster/src/main/java/org/apache/qpid/server/cluster/Main.java b/java/cluster/src/main/java/org/apache/qpid/server/cluster/Main.java
index 3eeddd7b4e..5746a32c26 100644
--- a/java/cluster/src/main/java/org/apache/qpid/server/cluster/Main.java
+++ b/java/cluster/src/main/java/org/apache/qpid/server/cluster/Main.java
@@ -83,7 +83,7 @@ public class Main extends org.apache.qpid.server.Main
// implementation provided by MINA
if (connectorConfig.enableExecutorPool)
{
- sconfig.setThreadModel(new ReadWriteThreadModel());
+ sconfig.setThreadModel(ReadWriteThreadModel.getInstance());
}
String host = InetAddress.getLocalHost().getHostName();