Code Review
/
nonrtric.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Add SDNR A1 client in policy-agent
[nonrtric.git]
/
policy-agent
/
src
/
main
/
java
/
org
/
oransc
/
policyagent
/
dmaap
/
DmaapMessageConsumerImpl.java
diff --git
a/policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerImpl.java
b/policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerImpl.java
index
2ae5e5e
..
c7dab58
100644
(file)
--- a/
policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerImpl.java
+++ b/
policy-agent/src/main/java/org/oransc/policyagent/dmaap/DmaapMessageConsumerImpl.java
@@
-22,7
+22,6
@@
package org.oransc.policyagent.dmaap;
import java.io.IOException;
import java.util.Properties;
import java.io.IOException;
import java.util.Properties;
-import javax.annotation.PostConstruct;
import org.onap.dmaap.mr.client.MRClientFactory;
import org.onap.dmaap.mr.client.MRConsumer;
import org.onap.dmaap.mr.client.response.MRConsumerResponse;
import org.onap.dmaap.mr.client.MRClientFactory;
import org.onap.dmaap.mr.client.MRConsumer;
import org.onap.dmaap.mr.client.response.MRConsumerResponse;
@@
-55,9
+54,9
@@
public class DmaapMessageConsumerImpl implements DmaapMessageConsumer {
@Scheduled(fixedRate = 1000 * 10) // , initialDelay=60000)
@Override
public void run() {
@Scheduled(fixedRate = 1000 * 10) // , initialDelay=60000)
@Override
public void run() {
- /*
- * if (!alive) { init(); }
- */
+ if (!alive) {
+ init();
+ }
if (this.alive) {
try {
Iterable<String> dmaapMsgs = fetchAllMessages();
if (this.alive) {
try {
Iterable<String> dmaapMsgs = fetchAllMessages();
@@
-85,7
+84,6
@@
public class DmaapMessageConsumerImpl implements DmaapMessageConsumer {
return response.getActualMessages();
}
return response.getActualMessages();
}
- @PostConstruct
@Override
public void init() {
Properties dmaapConsumerProperties = applicationConfig.getDmaapConsumerConfig();
@Override
public void init() {
Properties dmaapConsumerProperties = applicationConfig.getDmaapConsumerConfig();
@@
-98,6
+96,8
@@
public class DmaapMessageConsumerImpl implements DmaapMessageConsumer {
}
try {
logger.debug("Creating DMAAP Client");
}
try {
logger.debug("Creating DMAAP Client");
+ logger.debug("dmaapConsumerProperties---> {}", dmaapConsumerProperties.getProperty("topic"));
+ logger.debug("dmaapPublisherProperties---> {}", dmaapPublisherProperties.getProperty("topic"));
consumer = MRClientFactory.createConsumer(dmaapConsumerProperties);
this.alive = true;
} catch (IOException e) {
consumer = MRClientFactory.createConsumer(dmaapConsumerProperties);
this.alive = true;
} catch (IOException e) {