summaryrefslogtreecommitdiff
path: root/qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java
diff options
context:
space:
mode:
authorAidan Skinner <aidan@apache.org>2009-09-16 10:07:44 +0000
committerAidan Skinner <aidan@apache.org>2009-09-16 10:07:44 +0000
commit23ed5eb6dbd7cf39cf18b308a0d4e339c4db1c83 (patch)
tree55727c0c91521d8be6bbe99fd5baf60d07e50009 /qpid/java/broker/src/main/java/org/apache/qpid/server/virtualhost/VirtualHost.java
parent9c4ecc45da929750ff7f0e0a5d7ada4e674b9105 (diff)
downloadqpid-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.java8
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();
+ }
+ }
}
}