Updated Branches: refs/heads/master 2f2ceed86 -> ede69d5cd
Add debug log Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/ede69d5c Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/ede69d5c Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/ede69d5c Branch: refs/heads/master Commit: ede69d5cdedd8acd7ce4e1f1ad2b3cbcf2f61e19 Parents: 2f2ceed Author: Manula Thantriwatte <[email protected]> Authored: Wed Dec 18 21:25:47 2013 +0530 Committer: Manula Thantriwatte <[email protected]> Committed: Wed Dec 18 21:25:47 2013 +0530 ---------------------------------------------------------------------- .../stratos/cep/extension/FaultHandlingWindowProcessor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/ede69d5c/extensions/cep/stratos-cep-extension/src/main/java/org/apache/stratos/cep/extension/FaultHandlingWindowProcessor.java ---------------------------------------------------------------------- diff --git a/extensions/cep/stratos-cep-extension/src/main/java/org/apache/stratos/cep/extension/FaultHandlingWindowProcessor.java b/extensions/cep/stratos-cep-extension/src/main/java/org/apache/stratos/cep/extension/FaultHandlingWindowProcessor.java index 34c6532..83ecc43 100644 --- a/extensions/cep/stratos-cep-extension/src/main/java/org/apache/stratos/cep/extension/FaultHandlingWindowProcessor.java +++ b/extensions/cep/stratos-cep-extension/src/main/java/org/apache/stratos/cep/extension/FaultHandlingWindowProcessor.java @@ -109,9 +109,9 @@ public class FaultHandlingWindowProcessor extends WindowProcessor implements Run InEvent event = (InEvent)pair.getValue(); if ((currentTime - event.getTimeStamp()) / MILI_TO_MINUTE > TIME_OUT) { - log.info("Member Inactive : " + pair.getKey()); + log.info("Member Inactive : " + pair.getKey() + " : " + "for " + TIME_OUT + " seconds"); it.remove(); - log.debug("Inactive member : " + pair.getKey()); + log.debug("Inactive member : " + pair.getKey() + " : " + "for " + TIME_OUT + " seconds"); nextProcessor.process(event); } }
