Code Review
/
dmaap
/
datarouter.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Fix checkstyle contridictions on datarouter node
[dmaap/datarouter.git]
/
datarouter-node
/
src
/
main
/
java
/
org
/
onap
/
dmaap
/
datarouter
/
node
/
NodeMain.java
diff --git
a/datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/NodeMain.java
b/datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/NodeMain.java
index
6086168
..
988b05e
100644
(file)
--- a/
datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/NodeMain.java
+++ b/
datarouter-node/src/main/java/org/onap/dmaap/datarouter/node/NodeMain.java
@@
-60,6
+60,7
@@
public class NodeMain {
/**
* Reset the retry timer for a subscription.
*/
/**
* Reset the retry timer for a subscription.
*/
+
static void resetQueue(String subid, String ip) {
delivery.resetQueue(nodeConfigManager.getSpoolDir(subid, ip));
}
static void resetQueue(String subid, String ip) {
delivery.resetQueue(nodeConfigManager.getSpoolDir(subid, ip));
}
@@
-155,7
+156,8
@@
public class NodeMain {
server.start();
nodeMainLogger.debug("NODE00006 Node Server started-" + server.getState());
} catch (Exception e) {
server.start();
nodeMainLogger.debug("NODE00006 Node Server started-" + server.getState());
} catch (Exception e) {
- nodeMainLogger.error("NODE00006 Jetty failed to start. Reporting will we unavailable: " + e.getMessage(), e);
+ nodeMainLogger.error("NODE00006 Jetty failed to start. Reporting will we unavailable: "
+ + e.getMessage(), e);
}
server.join();
nodeMainLogger.debug("NODE00007 Node Server joined - " + server.getState());
}
server.join();
nodeMainLogger.debug("NODE00007 Node Server joined - " + server.getState());