diff options
Diffstat (limited to 'src/main/java/org/onap/dcaegen2/services/sonhms/dmaap/PolicyDmaapClient.java')
-rw-r--r-- | src/main/java/org/onap/dcaegen2/services/sonhms/dmaap/PolicyDmaapClient.java | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/dmaap/PolicyDmaapClient.java b/src/main/java/org/onap/dcaegen2/services/sonhms/dmaap/PolicyDmaapClient.java index a0a1274..1a8456f 100644 --- a/src/main/java/org/onap/dcaegen2/services/sonhms/dmaap/PolicyDmaapClient.java +++ b/src/main/java/org/onap/dcaegen2/services/sonhms/dmaap/PolicyDmaapClient.java @@ -38,16 +38,15 @@ import org.slf4j.Logger; public class PolicyDmaapClient { private static final Logger log = org.slf4j.LoggerFactory.getLogger(PolicyDmaapClient.class); - + private DmaapUtils dmaapUtils; - + private Configuration configuration; - - + public PolicyDmaapClient(DmaapUtils dmaapUtils, Configuration configuration) { this.dmaapUtils = dmaapUtils; this.configuration = configuration; - } + } /** * Method stub for sending notification to policy. @@ -71,7 +70,7 @@ public class PolicyDmaapClient { } return true; } - + /** * Handles policy response. */ @@ -91,7 +90,7 @@ public class PolicyDmaapClient { Timestamp currentTime = new Timestamp(System.currentTimeMillis()); Long difference = currentTime.getTime() - startTimer.getTime(); int policyRespTimer = configuration.getPolicyRespTimer(); // Timer in seconds - while (difference < (policyRespTimer*1000)) { + while (difference < (policyRespTimer * 1000)) { Iterable<String> policyResponseMessages; try { policyResponseMessages = policyResponseCambriaConsumer.fetch(); |