From 49e77b6405ef7d286bdd667f2a689b20022351fc Mon Sep 17 00:00:00 2001 From: Jim Hahn Date: Wed, 9 May 2018 17:06:59 -0400 Subject: Discard Forward to wrong host Changed to discard Forward message if the channel does not match the host that received it. Change-Id: I9235bd3b0c5eb264f9b1cfe53552fadf66a0edc2 Issue-ID: POLICY-787 Signed-off-by: Jim Hahn --- .../src/main/java/org/onap/policy/drools/pooling/state/State.java | 5 +++++ 1 file changed, 5 insertions(+) (limited to 'feature-pooling-dmaap/src/main/java/org') diff --git a/feature-pooling-dmaap/src/main/java/org/onap/policy/drools/pooling/state/State.java b/feature-pooling-dmaap/src/main/java/org/onap/policy/drools/pooling/state/State.java index 545c2ef0..fcb0e139 100644 --- a/feature-pooling-dmaap/src/main/java/org/onap/policy/drools/pooling/state/State.java +++ b/feature-pooling-dmaap/src/main/java/org/onap/policy/drools/pooling/state/State.java @@ -147,6 +147,11 @@ public abstract class State { * @return the new state, or {@code null} if the state is unchanged */ public State process(Forward msg) { + if(!getHost().equals(msg.getChannel())) { + logger.info("discard Forward message to {} from {} on topic {}", msg.getChannel(), msg.getSource(), getTopic()); + return null; + } + logger.info("received Forward message from {} on topic {}", msg.getSource(), getTopic()); mgr.handle(msg); return null; -- cgit 1.2.3-korg