import javax.servlet.ServletConfig;\r
import javax.servlet.ServletException;\r
import javax.servlet.http.HttpServletRequest;\r
import javax.servlet.ServletConfig;\r
import javax.servlet.ServletException;\r
import javax.servlet.http.HttpServletRequest;\r
import org.onap.dmaap.datarouter.provisioning.beans.IngressRoute;\r
import org.onap.dmaap.datarouter.provisioning.eelf.EelfMsgs;\r
import org.onap.dmaap.datarouter.provisioning.utils.DB;\r
import org.onap.dmaap.datarouter.provisioning.beans.IngressRoute;\r
import org.onap.dmaap.datarouter.provisioning.eelf.EelfMsgs;\r
import org.onap.dmaap.datarouter.provisioning.utils.DB;\r
* @version $Id: PublishServlet.java,v 1.8 2014/03/12 19:45:41 eby Exp $\r
*/\r
@SuppressWarnings("serial")\r
* @version $Id: PublishServlet.java,v 1.8 2014/03/12 19:45:41 eby Exp $\r
*/\r
@SuppressWarnings("serial")\r
public class PublishServlet extends BaseServlet {\r
\r
private int nextNode;\r
private String provstring;\r
private List<IngressRoute> irt;\r
//Adding EELF Logger Rally:US664892\r
public class PublishServlet extends BaseServlet {\r
\r
private int nextNode;\r
private String provstring;\r
private List<IngressRoute> irt;\r
//Adding EELF Logger Rally:US664892\r
- eelflogger.info(EelfMsgs.MESSAGE_WITH_BEHALF_AND_FEEDID, req.getHeader(BEHALF_HEADER), getIdFromPath(req) + "");\r
+ eelfLogger.info(EelfMsgs.MESSAGE_WITH_BEHALF_AND_FEEDID,\r
+ req.getHeader(BEHALF_HEADER), getIdFromPath(req) + "");\r
- eelflogger.info(EelfMsgs.MESSAGE_WITH_BEHALF_AND_FEEDID, req.getHeader(BEHALF_HEADER), getIdFromPath(req) + "");\r
- redirect(req, resp);\r
+ eelfLogger.info(EelfMsgs.MESSAGE_WITH_BEHALF_AND_FEEDID,\r
+ req.getHeader(BEHALF_HEADER), getIdFromPath(req) + "");\r
+ redirect(req, resp);\r
- eelflogger.info(EelfMsgs.MESSAGE_WITH_BEHALF_AND_FEEDID, req.getHeader(BEHALF_HEADER), getIdFromPath(req) + "");\r
- redirect(req, resp);\r
+ eelfLogger.info(EelfMsgs.MESSAGE_WITH_BEHALF_AND_FEEDID,\r
+ req.getHeader(BEHALF_HEADER), getIdFromPath(req) + "");\r
+ redirect(req, resp);\r
setIpFqdnForEelf(method);\r
} else {\r
setIpFqdnRequestIDandInvocationIDForEelf(method, req);\r
}\r
}\r
\r
setIpFqdnForEelf(method);\r
} else {\r
setIpFqdnRequestIDandInvocationIDForEelf(method, req);\r
}\r
}\r
\r
: "Invalid request - Missing file ID.";\r
elr.setMessage(message);\r
elr.setResult(HttpServletResponse.SC_NOT_FOUND);\r
: "Invalid request - Missing file ID.";\r
elr.setMessage(message);\r
elr.setResult(HttpServletResponse.SC_NOT_FOUND);\r
String message = "Redirected to: " + newurl;\r
elr.setMessage(message);\r
elr.setResult(HttpServletResponse.SC_MOVED_PERMANENTLY);\r
String message = "Redirected to: " + newurl;\r
elr.setMessage(message);\r
elr.setResult(HttpServletResponse.SC_MOVED_PERMANENTLY);\r
\r
resp.setStatus(HttpServletResponse.SC_MOVED_PERMANENTLY);\r
resp.setHeader("Location", newurl);\r
}\r
}\r
} catch (IOException ioe) {\r
\r
resp.setStatus(HttpServletResponse.SC_MOVED_PERMANENTLY);\r
resp.setHeader("Location", newurl);\r
}\r
}\r
} catch (IOException ioe) {\r
}\r
}\r
\r
private String getRedirectNode(int feedid, HttpServletRequest req) {\r
// Check to see if the IRT needs to be updated\r
}\r
}\r
\r
private String getRedirectNode(int feedid, HttpServletRequest req) {\r
// Check to see if the IRT needs to be updated\r
JSONObject jo = new JSONObject(new JSONTokener(provstring));\r
JSONArray ja = jo.getJSONArray("ingress");\r
List<IngressRoute> newlist = new ArrayList<>();\r
JSONObject jo = new JSONObject(new JSONTokener(provstring));\r
JSONArray ja = jo.getJSONArray("ingress");\r
List<IngressRoute> newlist = new ArrayList<>();\r
\r
// No IRT rule matches, do round robin of all active nodes\r
String[] nodes = getNodes();\r
\r
// No IRT rule matches, do round robin of all active nodes\r
String[] nodes = getNodes();\r