Repository: activemq Updated Branches: refs/heads/master 31d99b6aa -> 93092f7ea
https://issues.apache.org/jira/browse/AMQ-6070 - rework regression - KahaDBStoreRecoveryExpiryTest had NPE in the logs, region dest not set on recovery listener for expiry case Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/93092f7e Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/93092f7e Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/93092f7e Branch: refs/heads/master Commit: 93092f7ea0e231cd7d615f8ee6420c9b73a5367f Parents: 31d99b6 Author: gtully <[email protected]> Authored: Fri Dec 11 15:27:28 2015 +0000 Committer: gtully <[email protected]> Committed: Fri Dec 11 15:27:28 2015 +0000 ---------------------------------------------------------------------- .../src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java | 2 +- .../src/main/java/org/apache/activemq/broker/region/Queue.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/93092f7e/activemq-broker/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java ---------------------------------------------------------------------- diff --git a/activemq-broker/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java b/activemq-broker/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java index d7c9aa8..8ad3bac 100755 --- a/activemq-broker/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java +++ b/activemq-broker/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java @@ -772,7 +772,7 @@ public class AdvisoryBroker extends BrokerFilter { private void handleFireFailure(String message, Throwable cause) { LOG.warn("Failed to fire {} advisory, reason: {}", message, cause); - LOG.debug("{} detail: {}", message, cause); + LOG.debug("{} detail: {}", message, cause, cause); } protected void fireAdvisory(ConnectionContext context, ActiveMQTopic topic, Command command) throws Exception { http://git-wip-us.apache.org/repos/asf/activemq/blob/93092f7e/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java ---------------------------------------------------------------------- diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java b/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java index adc3a53..d447ebd 100755 --- a/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java +++ b/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java @@ -286,12 +286,12 @@ public class Queue extends BaseDestination implements Task, UsageListener, Index } // Message could have expired while it was being // loaded.. + message.setRegionDestination(Queue.this); if (message.isExpired() && broker.isExpired(message)) { toExpire.add(message); return true; } if (hasSpace()) { - message.setRegionDestination(Queue.this); messagesLock.writeLock().lock(); try { try {
