Author: rgodfrey
Date: Wed Nov 30 12:23:55 2016
New Revision: 1772019
URL: http://svn.apache.org/viewvc?rev=1772019&view=rev
Log:
QPID-7514 : recreate the virtual host housekeeping executor on restart if it
has been terminated
Modified:
qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
Modified:
qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
URL:
http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java?rev=1772019&r1=1772018&r2=1772019&view=diff
==============================================================================
---
qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
(original)
+++
qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractVirtualHost.java
Wed Nov 30 12:23:55 2016
@@ -594,11 +594,17 @@ public abstract class AbstractVirtualHos
PreferencesRoot preferencesRoot = getParent(VirtualHostNode.class);
_preferenceStore = preferencesRoot.createPreferenceStore();
- _houseKeepingTaskExecutor = new HousekeepingExecutor("virtualhost-" +
getName() + "-pool",
-
getHousekeepingThreadCount(),
-
getSystemTaskSubject("Housekeeping", getPrincipal()));
-
+ createHousekeepingExecutor();
+ }
+ private void createHousekeepingExecutor()
+ {
+ if(_houseKeepingTaskExecutor == null ||
_houseKeepingTaskExecutor.isTerminated())
+ {
+ _houseKeepingTaskExecutor = new
HousekeepingExecutor("virtualhost-" + getName() + "-pool",
+
getHousekeepingThreadCount(),
+
getSystemTaskSubject("Housekeeping", getPrincipal()));
+ }
}
private void checkVHostStateIsActive()
@@ -2568,7 +2574,7 @@ public abstract class AbstractVirtualHos
private ListenableFuture<Void> onRestart()
{
resetStatistics();
-
+ createHousekeepingExecutor();
final List<ConfiguredObjectRecord> records = new ArrayList<>();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
