package org.onap.dmaap.datarouter.node;
-import java.net.*;
-import java.util.*;
-import java.io.*;
-
-import org.apache.log4j.Logger;
-import org.onap.dmaap.datarouter.node.eelf.EelfMsgs;
-
import com.att.eelf.configuration.EELFLogger;
import com.att.eelf.configuration.EELFManager;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.InputStreamReader;
+import java.io.Reader;
+import java.net.URL;
+import java.util.Properties;
+import java.util.Timer;
+import org.apache.log4j.Logger;
+import org.onap.dmaap.datarouter.node.eelf.EelfMsgs;
/**
* Maintain the configuration of a Data Router node
* <p>
- * The NodeConfigManager is the single point of contact for servlet, delivery, event logging, and log retention subsystems to access configuration information. (Log4J has its own configuration mechanism).
+ * The NodeConfigManager is the single point of contact for servlet, delivery, event logging, and log retention
+ * subsystems to access configuration information. (Log4J has its own configuration mechanism).
* <p>
- * There are two basic sets of configuration data. The
- * static local configuration data, stored in a local configuration file (created
- * as part of installation by SWM), and the dynamic global
- * configuration data fetched from the data router provisioning server.
+ * There are two basic sets of configuration data. The static local configuration data, stored in a local configuration
+ * file (created as part of installation by SWM), and the dynamic global configuration data fetched from the data router
+ * provisioning server.
*/
public class NodeConfigManager implements DeliveryQueueHelper {
- private static EELFLogger eelflogger = EELFManager.getInstance().getLogger("org.onap.dmaap.datarouter.node.NodeConfigManager");
+
+ private static EELFLogger eelflogger = EELFManager.getInstance()
+ .getLogger(NodeConfigManager.class);
private static Logger logger = Logger.getLogger("org.onap.dmaap.datarouter.node.NodeConfigManager");
private static NodeConfigManager base = new NodeConfigManager();
private NodeConfigManager() {
Properties p = new Properties();
try {
- p.load(new FileInputStream(System.getProperty("org.onap.dmaap.datarouter.node.ConfigFile", "/opt/app/datartr/etc/node.properties")));
+ p.load(new FileInputStream(System
+ .getProperty("org.onap.dmaap.datarouter.node.properties", "/opt/app/datartr/etc/node.properties")));
} catch (Exception e) {
NodeUtils.setIpAndFqdnForEelf("NodeConfigManager");
eelflogger.error(EelfMsgs.MESSAGE_PROPERTIES_LOAD_ERROR);
- logger.error("NODE0301 Unable to load local configuration file " + System.getProperty("org.onap.dmaap.datarouter.node.ConfigFile", "/opt/app/datartr/etc/node.properties"), e);
+ logger.error("NODE0301 Unable to load local configuration file " + System
+ .getProperty("org.onap.dmaap.datarouter.node.properties", "/opt/app/datartr/etc/node.properties"),
+ e);
}
provurl = p.getProperty("ProvisioningURL", "https://feeds-drtr.web.att.com/internal/prov");
try {
private void localconfig() {
followredirects = Boolean.parseBoolean(getProvParam("FOLLOW_REDIRECTS", "false"));
- eventloginterval = getProvParam("LOGROLL_INTERVAL", "5m");
+ eventloginterval = getProvParam("LOGROLL_INTERVAL", "30s");
initfailuretimer = 10000;
maxfailuretimer = 3600000;
expirationtimer = 86400000;
}
}
} catch (Exception e) {
- e.printStackTrace();
NodeUtils.setIpAndFqdnForEelf("fetchconfigs");
eelflogger.error(EelfMsgs.MESSAGE_CONF_FAILED, e.toString());
logger.error("NODE0306 Configuration failed " + e.toString() + " - try again later", e);
}
/**
- * Process a gofetch request from a particular IP address. If the
- * IP address is not an IP address we would go to to fetch the
- * provisioning data, ignore the request. If the data has been
- * fetched very recently (default 10 seconds), wait a while before fetching again.
+ * Process a gofetch request from a particular IP address. If the IP address is not an IP address we would go to to
+ * fetch the provisioning data, ignore the request. If the data has been fetched very recently (default 10
+ * seconds), wait a while before fetching again.
*/
public synchronized void gofetch(String remoteaddr) {
if (provcheck.isFrom(remoteaddr)) {
* Given a set of credentials and an IP address, is this request from another node?
*
* @param credentials Credentials offered by the supposed node
- * @param ip IP address the request came from
+ * @param ip IP address the request came from
* @return If the credentials and IP address are recognized, true, otherwise false.
*/
public boolean isAnotherNode(String credentials, String ip) {
/**
* Check whether publication is allowed.
*
- * @param feedid The ID of the feed being requested
+ * @param feedid The ID of the feed being requested
* @param credentials The offered credentials
- * @param ip The requesting IP address
+ * @param ip The requesting IP address
* @return True if the IP and credentials are valid for the specified feed.
*/
public String isPublishPermitted(String feedid, String credentials, String ip) {
/**
* Check who the user is given the feed ID and the offered credentials.
*
- * @param feedid The ID of the feed specified
+ * @param feedid The ID of the feed specified
* @param credentials The offered credentials
* @return Null if the credentials are invalid or the user if they are valid.
*/
* Check if the publish request should be sent to another node based on the feedid, user, and source IP address.
*
* @param feedid The ID of the feed specified
- * @param user The publishing user
- * @param ip The IP address of the publish endpoint
+ * @param user The publishing user
+ * @param ip The IP address of the publish endpoint
* @return Null if the request should be accepted or the correct hostname if it should be sent to another node.
*/
public String getIngressNode(String feedid, String user, String ip) {
/**
* Get a provisioned configuration parameter (from the provisioning server configuration)
*
- * @param name The name of the parameter
- * @param deflt The value to use if the parameter is not defined
+ * @param name The name of the parameter
+ * @param defaultValue The value to use if the parameter is not defined
* @return The value of the parameter or deflt if it is not defined.
*/
- public String getProvParam(String name, String deflt) {
+ public String getProvParam(String name, String defaultValue) {
name = config.getProvParam(name);
if (name == null) {
- name = deflt;
+ name = defaultValue;
}
return (name);
}
}
/**
- * Get all the outbound spooling destinations.
- * This will include both subscriptions and nodes.
+ * Get all the outbound spooling destinations. This will include both subscriptions and nodes.
*/
public DestInfo[] getAllDests() {
return (config.getAllDests());
* Get the URL to deliver a message to.
*
* @param destinfo The destination information
- * @param fileid The file ID
+ * @param fileid The file ID
* @return The URL to deliver to
*/
public String getDestURL(DestInfo destinfo, String fileid) {
}
/**
- * Get the maximum number of file delivery attempts before checking
- * if another queue has work to be performed.
+ * Get the maximum number of file delivery attempts before checking if another queue has work to be performed.
*/
public int getFairFileLimit() {
return (fairfilelimit);
}
/**
- * Get the maximum amount of time spent delivering files before
- * checking if another queue has work to be performed.
+ * Get the maximum amount of time spent delivering files before checking if another queue has work to be performed.
*/
public long getFairTimeLimit() {
return (fairtimelimit);
}
/**
- * Get the fraction of free spool disk space where we start throwing away undelivered files. This is FREE_DISK_RED_PERCENT / 100.0. Default is 0.05. Limited by 0.01 <= FreeDiskStart <= 0.5.
+ * Get the fraction of free spool disk space where we start throwing away undelivered files. This is
+ * FREE_DISK_RED_PERCENT / 100.0. Default is 0.05. Limited by 0.01 <= FreeDiskStart <= 0.5.
*/
public double getFreeDiskStart() {
return (fdpstart);
}
/**
- * Get the fraction of free spool disk space where we stop throwing away undelivered files. This is FREE_DISK_YELLOW_PERCENT / 100.0. Default is 0.2. Limited by FreeDiskStart <= FreeDiskStop <= 0.5.
+ * Get the fraction of free spool disk space where we stop throwing away undelivered files. This is
+ * FREE_DISK_YELLOW_PERCENT / 100.0. Default is 0.2. Limited by FreeDiskStart <= FreeDiskStop <= 0.5.
*/
public double getFreeDiskStop() {
return (fdpstop);
if (provcheck.isFrom(remoteaddr)) {
String sdir = config.getSpoolDir(subid);
if (sdir != null) {
- logger.info("NODE0310 Received subscription reset request for subscription " + subid + " from provisioning server " + remoteaddr);
+ logger.info("NODE0310 Received subscription reset request for subscription " + subid
+ + " from provisioning server " + remoteaddr);
} else {
- logger.info("NODE0311 Received subscription reset request for unknown subscription " + subid + " from provisioning server " + remoteaddr);
+ logger.info("NODE0311 Received subscription reset request for unknown subscription " + subid
+ + " from provisioning server " + remoteaddr);
}
return (sdir);
} else {
Code Review / dmaap / datarouter.git / blobdiff