diff options
| author |   ITSERVICES\rb7147 <rb7147@att.com> | 2017-05-08 22:20:44 -0400 |
|---|---|---|
| committer | ITSERVICES\rb7147 <rb7147@att.com> | 2017-05-09 13:58:03 -0400 |
| commit | dda032f8bb161d54eb1f59de2b4a3efb774fc4d1 (patch) | |
| tree | 9a11825d59434d97bb0c7dcbf00a0b84e7e5f526 /PolicyEngineAPI/src/main/java/org/openecomp/policy/std/AutoClientUEB.java | |
| parent | a330af579866dacbe595e2e4ad1dd29cd3c96945 (diff) | |
Policy 1707 Second commit
Change-Id: I18f5b142238733d17280cf17c3d1dd28204d34e9
Signed-off-by: ITSERVICES\rb7147 <rb7147@att.com>
Diffstat (limited to 'PolicyEngineAPI/src/main/java/org/openecomp/policy/std/AutoClientUEB.java')
| -rw-r--r-- | PolicyEngineAPI/src/main/java/org/openecomp/policy/std/AutoClientUEB.java | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/PolicyEngineAPI/src/main/java/org/openecomp/policy/std/AutoClientUEB.java b/PolicyEngineAPI/src/main/java/org/openecomp/policy/std/AutoClientUEB.java index 40bd8012a..91d81d043 100644 --- a/PolicyEngineAPI/src/main/java/org/openecomp/policy/std/AutoClientUEB.java +++ b/PolicyEngineAPI/src/main/java/org/openecomp/policy/std/AutoClientUEB.java @@ -30,22 +30,19 @@ import org.openecomp.policy.api.NotificationHandler; import org.openecomp.policy.api.NotificationScheme; import org.openecomp.policy.api.NotificationType; import org.openecomp.policy.api.PDPNotification; -import org.openecomp.policy.std.StdPDPNotification; -import org.openecomp.policy.xacml.api.XACMLErrorConstants; import org.openecomp.policy.common.logging.flexlogger.FlexLogger; import org.openecomp.policy.common.logging.flexlogger.Logger; +import org.openecomp.policy.xacml.api.XACMLErrorConstants; import com.att.nsa.cambria.client.CambriaClientBuilders; -import com.att.nsa.cambria.client.CambriaClientFactory; -import com.att.nsa.cambria.client.CambriaConsumer; import com.att.nsa.cambria.client.CambriaClientBuilders.ConsumerBuilder; +import com.att.nsa.cambria.client.CambriaConsumer; /** * Create a UEB Consumer to receive policy update notification. * * * */ -@SuppressWarnings("deprecation") public class AutoClientUEB implements Runnable { private static StdPDPNotification notification = null; private static NotificationScheme scheme = null; @@ -117,8 +114,6 @@ public class AutoClientUEB implements Runnable { } catch (MalformedURLException e) { topic = AutoClientUEB.url.replace("[:/]", ""); } - - //TODO create a loop to listen for messages from UEB cluster try { //CConsumer = CambriaClientFactory.createConsumer ( null, uebURLList, topic, group, id, 15*1000, 1000 ); @@ -147,7 +142,6 @@ public class AutoClientUEB implements Runnable { callHandler(); } } catch (Exception e) { - // TODO Auto-generated catch block logger.debug(XACMLErrorConstants.ERROR_SYSTEM_ERROR + "Error in processing UEB message" + e.getMessage()); } |