import java.util.Date;
import java.util.List;
import org.json.JSONObject;
+import org.onap.dcae.ApplicationException;
import org.onap.dcae.ApplicationSettings;
import org.onap.dcae.common.publishing.EventPublisher;
import org.slf4j.Logger;
public class EventSender {
+ private static final String COULD_NOT_FIND_FILE = "Couldn't find file ./etc/eventTransform.json";
private Map<String, String[]> streamidHash;
private ApplicationSettings properties;
private EventPublisher eventPublisher;
- static final Type EVENT_LIST_TYPE = new TypeToken<List<Event>>() {}.getType();
+ private static final Type EVENT_LIST_TYPE = new TypeToken<List<Event>>() {}.getType();
private static final Logger log = LoggerFactory.getLogger(EventSender.class);
private static final String EVENT_LITERAL = "event";
private static final String COMMON_EVENT_HEADER = "commonEventHeader";
List<Event> events = new Gson().fromJson(fr, EVENT_LIST_TYPE);
parseEventsJson(events, new ConfigProcessorAdapter(new ConfigProcessors(jsonObject)));
} catch (IOException e) {
- log.error("Couldn't find file ./etc/eventTransform.json" + e.toString());
+ log.error(COULD_NOT_FIND_FILE, e);
+ throw new ApplicationException(COULD_NOT_FIND_FILE, e);
}
}
if (jsonObject.has("VESversion"))
import com.att.nsa.logging.LoggingContext;
import com.att.nsa.logging.LoggingContextFactory;
import com.att.nsa.logging.log4j.EcompFields;
-import jline.internal.Log;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import java.net.InetAddress;
-import java.net.UnknownHostException;
import java.util.UUID;
public class VESLogger {
@RestController
public class VesRestController {
- private static final Logger log = LoggerFactory.getLogger(VesRestController.class);
+ private static final Logger log = LoggerFactory.getLogger(VesRestController.class);
+ private static final String INVALID_JSON = ApiException.INVALID_JSON_INPUT.toJSON().toString();
private final ApplicationSettings applicationSettings;
private final LinkedBlockingQueue<JSONObject> inputQueue;
-
private final Logger metricsLog;
private final Logger errorLog;
private final Logger incomingRequestsLogger;
try {
jsonObject = new JSONObject(jsonPayload);
} catch (Exception e) {
- return ResponseEntity.badRequest().body(ApiException.INVALID_JSON_INPUT.toJSON().toString());
+ log.error(INVALID_JSON);
+ return ResponseEntity.badRequest().body(INVALID_JSON);
}
String uuid = setUpECOMPLoggingForRequest();