Updated Branches: refs/heads/trunk 8d31e44e8 -> 5515b9be3
Fix for https://issues.apache.org/jira/browse/AMQ-4714 Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/5515b9be Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/5515b9be Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/5515b9be Branch: refs/heads/trunk Commit: 5515b9be3fbbef3289844eefd1514e0ae37a5b01 Parents: 8d31e44 Author: rajdavies <[email protected]> Authored: Fri Sep 6 14:02:10 2013 +0100 Committer: rajdavies <[email protected]> Committed: Fri Sep 6 14:02:10 2013 +0100 ---------------------------------------------------------------------- .../activemq/broker/inteceptor/MessageInterceptorRegistry.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/5515b9be/activemq-broker/src/main/java/org/apache/activemq/broker/inteceptor/MessageInterceptorRegistry.java ---------------------------------------------------------------------- diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/inteceptor/MessageInterceptorRegistry.java b/activemq-broker/src/main/java/org/apache/activemq/broker/inteceptor/MessageInterceptorRegistry.java index 6dbb8aa..f906394 100644 --- a/activemq-broker/src/main/java/org/apache/activemq/broker/inteceptor/MessageInterceptorRegistry.java +++ b/activemq-broker/src/main/java/org/apache/activemq/broker/inteceptor/MessageInterceptorRegistry.java @@ -56,7 +56,8 @@ public class MessageInterceptorRegistry { } private MessageInterceptorRegistry(){ - this.brokerService=null; + this.brokerService=BrokerRegistry.getInstance().findFirst(); + messageInterceptorRegistryMap.put(brokerService,this); } private MessageInterceptorRegistry(BrokerService brokerService) {
