*/
package org.onap.dmaap.datarouter.provisioning.utils;
-import org.apache.log4j.Logger;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
import org.onap.aaf.cadi.PropAccess;
import org.onap.aaf.cadi.filter.CadiFilter;
import org.onap.dmaap.datarouter.provisioning.BaseServlet;
public class DRProvCadiFilter extends CadiFilter {
- private static Logger eventlogger = Logger.getLogger("org.onap.dmaap.datarouter.provisioning.events");
- private static Logger intlogger = Logger.getLogger("org.onap.dmaap.datarouter.provisioning.internal");
+ protected static EELFLogger eventlogger = EELFManager.getInstance().getLogger("EventLog");
+ protected static EELFLogger intlogger = EELFManager.getInstance().getLogger("InternalLog");
private String aafInstance = "";
public DRProvCadiFilter(boolean init, PropAccess access) throws ServletException {
@Override
public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
- HttpServletRequest httpRequest = null;
- HttpServletResponse httpResponse = null;
- //cadi code
- try {
- httpRequest = (HttpServletRequest) request;
- httpResponse = (HttpServletResponse) response;
- } catch (ClassCastException e) {
- try {
- throw new ServletException("Only serving HTTP today", e);
- } catch (ServletException e1) {
- intlogger.error("PROV7001 DRProvCadiFilter.doFilter: ", e1);
- }
- }
+ HttpServletRequest httpRequest = (HttpServletRequest) request;
+ HttpServletResponse httpResponse = (HttpServletResponse) response;
+
EventLogRecord elr = new EventLogRecord(httpRequest);
String excludeAAF = httpRequest.getHeader(BaseServlet.EXCLUDE_AAF_HEADER);//send this param value as true, if want to add legacy feed/subscriber in AAF env
String message = String.format("Invalid request URI - %s", httpRequest.getPathInfo());
elr.setMessage(message);
elr.setResult(HttpServletResponse.SC_NOT_FOUND);
- eventlogger.info(elr);
+ eventlogger.error(elr.toString());
httpResponse.sendError(HttpServletResponse.SC_NOT_FOUND, message);
return;
}
if (isAAFSubscriber(subId)) {//edit AAF Subscriber
String message = String.format("DRProvCadiFilter - Edit AAF Subscriber : %d : AAF Instance - %s", subId, aafInstance);
elr.setMessage(message);
- eventlogger.info(elr);
+ eventlogger.info(elr.toString());
//request.setAttribute("aafInstance", aafInstance);// no need to set it in request since it is taken care in respective servlets
super.doFilter(request, response, chain);
} else {//Edit or publish legacy Subscriber
String message = "DRProvCadiFilter - Edit/Publish Legacy Subscriber :" + subId;
elr.setMessage(message);
- eventlogger.info(elr);
+ eventlogger.info(elr.toString());
chain.doFilter(request, response);
}
String message = "Invalid request URI - " + httpRequest.getPathInfo();
elr.setMessage(message);
elr.setResult(HttpServletResponse.SC_NOT_FOUND);
- eventlogger.info(elr);
+ eventlogger.error(elr.toString());
httpResponse.sendError(HttpServletResponse.SC_NOT_FOUND, message);
return;
}
if (isAAFFeed(feedId)) {//edit AAF Feed
String message = "DRProvCadiFilter - Edit AAF Feed:" + feedId + ":" + "AAF Instance -" + aafInstance;
elr.setMessage(message);
- eventlogger.info(elr);
+ eventlogger.info(elr.toString());
super.doFilter(request, response, chain);
} else {//Edit or publish legacy Feed
String message = "DRProvCadiFilter - Edit/Publish Legacy Feed:" + feedId;
elr.setMessage(message);
- eventlogger.info(elr);
+ eventlogger.info(elr.toString());
chain.doFilter(request, response);
}
}
} else {// in all other cases defaults to legacy behavior
String message = "DRProvCadiFilter - Default Legacy Feed/Subscriber URI -:" + httpRequest.getPathInfo();
elr.setMessage(message);
- eventlogger.info(elr);
+ eventlogger.info(elr.toString());
chain.doFilter(request, response);
}
} else {
String message = "Invalid request URI - " + httpRequest.getPathInfo();
elr.setMessage(message);
elr.setResult(HttpServletResponse.SC_NOT_FOUND);
- eventlogger.info(elr);
+ eventlogger.error(elr.toString());
httpResponse.sendError(HttpServletResponse.SC_NOT_FOUND, message);
return;
}
String message = "DRProvCadiFilter -Invalid request Header Parmeter " + BaseServlet.EXCLUDE_AAF_HEADER + " = " + httpRequest.getHeader(BaseServlet.EXCLUDE_AAF_HEADER);
elr.setMessage(message);
elr.setResult(HttpServletResponse.SC_BAD_REQUEST);
- eventlogger.info(elr);
+ eventlogger.error(elr.toString());
httpResponse.sendError(HttpServletResponse.SC_BAD_REQUEST, message);
return;
}
if (excludeAAF.equalsIgnoreCase("true")) {//Check to add legacy subscriber to AAF Feed
String message = "DRProvCadiFilter - add legacy subscriber to AAF Feed, FeedID:" + feedId;
elr.setMessage(message);
- eventlogger.info(elr);
+ eventlogger.info(elr.toString());
chain.doFilter(request, response);
} else {
String message = "DRProvCadiFilter - Add AAF subscriber to AAF Feed, FeedID:" + feedId + ":" + "AAF Instance -" + aafInstance;
elr.setMessage(message);
- eventlogger.info(elr);
+ eventlogger.info(elr.toString());
super.doFilter(request, response, chain);
}
} else {//Add legacy susbcriber to legacy Feed
String message = "DRProvCadiFilter - add legacy subscriber to legacy Feed:" + feedId;
elr.setMessage(message);
- eventlogger.info(elr);
+ eventlogger.info(elr.toString());
chain.doFilter(request, response);
}
} else {//add AAF feed
String message = "DRProvCadiFilter -Invalid request Header Parmeter " + BaseServlet.EXCLUDE_AAF_HEADER + " = " + httpRequest.getHeader(BaseServlet.EXCLUDE_AAF_HEADER);
elr.setMessage(message);
elr.setResult(HttpServletResponse.SC_BAD_REQUEST);
- eventlogger.info(elr);
+ eventlogger.error(elr.toString());
httpResponse.sendError(HttpServletResponse.SC_BAD_REQUEST, message);
return;
}
if (excludeAAF.equalsIgnoreCase("true")) {//add legacy feed
String message = "DRProvCadiFilter - Create new legacy Feed : EXCLUDE_AAF = " + excludeAAF;
elr.setMessage(message);
- eventlogger.info(elr);
+ eventlogger.info(elr.toString());
chain.doFilter(request, response);
} else {//add AAF Feed
String message = "DRProvCadiFilter - Create new AAF Feed : EXCLUDE_AAF = " + excludeAAF;
elr.setMessage(message);
- eventlogger.info(elr);
+ eventlogger.info(elr.toString());
super.doFilter(request, response, chain);
}
}
}
} catch (Exception e) {
- intlogger.error("PROV0073 DRProvCadiFilter.isAAFFeed: ", e);
+ intlogger.error("PROV0073 DRProvCadiFilter.isAAFFeed: " + e.getMessage(), e);
return false;
}
return false;
intlogger.debug(message);
}
} catch (Exception e) {
- intlogger.error("PROV0073 DRProvCadiFilter.isAAFSubscriber: ", e);
+ intlogger.error("PROV0073 DRProvCadiFilter.isAAFSubscriber: " + e.getMessage(), e);
return false;
}
return false;