diff options
author | Aidan Skinner <aidan@apache.org> | 2009-09-16 10:07:44 +0000 |
---|---|---|
committer | Aidan Skinner <aidan@apache.org> | 2009-09-16 10:07:44 +0000 |
commit | 23ed5eb6dbd7cf39cf18b308a0d4e339c4db1c83 (patch) | |
tree | 55727c0c91521d8be6bbe99fd5baf60d07e50009 /qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java | |
parent | 9c4ecc45da929750ff7f0e0a5d7ada4e674b9105 (diff) | |
download | qpid-python-23ed5eb6dbd7cf39cf18b308a0d4e339c4db1c83.tar.gz |
QPID-2106: Don't close connections if the broker has asked it to close and
there's still stuff to process. Let the cleanup thread do that so that publishes
which are denied don't result in instant connection death.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-network-refactor@815705 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java')
-rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java index fa6b2285eb..aec437b700 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java @@ -267,6 +267,14 @@ public class VirtualHost implements Accessable _houseKeepingTimer.scheduleAtFixedRate(new RemoveExpiredMessagesTask(), period / 2, period); + + class ForceChannelClosuresTask extends TimerTask + { + public void run() + { + _connectionRegistry.expireClosedChannels(); + } + } } } |