Exclude advisory topics from the expired message check.
This commit is contained in:
Timothy Bish 2015-05-08 13:45:21 -04:00
parent a812131db7
commit 16a1e2b686
1 changed files with 1 additions and 1 deletions

View File

@ -560,7 +560,7 @@ public class Topic extends BaseDestination implements Task {
memoryUsage.start(); memoryUsage.start();
} }
if (getExpireMessagesPeriod() > 0) { if (getExpireMessagesPeriod() > 0 && !AdvisorySupport.isAdvisoryTopic(getActiveMQDestination())) {
scheduler.executePeriodically(expireMessagesTask, getExpireMessagesPeriod()); scheduler.executePeriodically(expireMessagesTask, getExpireMessagesPeriod());
} }
} }