Updated Branches: refs/heads/master 6db5968e4 -> 42af9be0a
Fixed complete topology message processor logic Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/42af9be0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/42af9be0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/42af9be0 Branch: refs/heads/master Commit: 42af9be0a5623b297caf92530df35a6159d79b2f Parents: 6db5968 Author: Imesh Gunaratne <[email protected]> Authored: Fri Dec 27 17:11:09 2013 +0530 Committer: Imesh Gunaratne <[email protected]> Committed: Fri Dec 27 17:11:09 2013 +0530 ---------------------------------------------------------------------- .../processor/topology/CompleteTopologyMessageProcessor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/42af9be0/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/CompleteTopologyMessageProcessor.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/CompleteTopologyMessageProcessor.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/CompleteTopologyMessageProcessor.java index 3c88df9..2a8850a 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/CompleteTopologyMessageProcessor.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/processor/topology/CompleteTopologyMessageProcessor.java @@ -58,7 +58,7 @@ public class CompleteTopologyMessageProcessor extends MessageProcessor { if (TopologyServiceFilter.getInstance().isActive()) { // Add services included in service filter for (Service service : event.getTopology().getServices()) { - if (TopologyServiceFilter.getInstance().serviceNameExcluded(service.getServiceName())) { + if (TopologyServiceFilter.getInstance().serviceNameIncluded(service.getServiceName())) { topology.addService(service); } else { if (log.isDebugEnabled()) {
