Method load has a Cognitive Complexity of 54 (exceeds 5 allowed). Consider refactoring.

Open

    @SuppressWarnings("unchecked")
    public void load(byte[] bytes) throws IOException {
        Object o = msgPack.unpack(bytes);
        if (o instanceof Map) {
            Map<String, Object> message = (Map<String, Object>) o;

• Read up
  Read up

File AsyncHttpRequest.java has 513 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/*

    Copyright 2018-2023 Accenture Technology

    Licensed under the Apache License, Version 2.0 (the "License");

EventEnvelope has 57 methods (exceeds 20 allowed). Consider refactoring.

Open

public class EventEnvelope {
    private static final Logger log = LoggerFactory.getLogger(EventEnvelope.class);

    private static final MsgPack msgPack = new MsgPack();
    private static final PayloadMapper converter = PayloadMapper.getInstance();

Method load has a Cognitive Complexity of 52 (exceeds 5 allowed). Consider refactoring.

Open

    @SuppressWarnings("unchecked")
    public void load(ConfigReader config) {
        if (config.exists(HEADERS)) {
            Object headerList = config.get(HEADERS);
            if (headerList instanceof List) {

• Read up
  Read up

Method loadRestEntry has 202 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @SuppressWarnings("unchecked")
    private void loadRestEntry(Map<String, Object> entry, boolean exact) {
        Utility util = Utility.getInstance();
        RouteInfo info = new RouteInfo();
        if ((entry.get(SERVICE) instanceof String || entry.get(SERVICE) instanceof List) &&

File LanguageConnector.java has 502 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/*

    Copyright 2018-2023 Accenture Technology

    Licensed under the Apache License, Version 2.0 (the "License");

AsyncHttpRequest has 56 methods (exceeds 20 allowed). Consider refactoring.

Open

public class AsyncHttpRequest {

    private static final PayloadMapper converter = PayloadMapper.getInstance();
    private static final String HTTP_HEADERS = "headers";
    private static final String HTTP_METHOD = "method";

PostOffice has 55 methods (exceeds 20 allowed). Consider refactoring.

Open

public class PostOffice {
    private static final Logger log = LoggerFactory.getLogger(PostOffice.class);

    public static final int ONE_MILLISECOND = 1000000;
    public static final String CLOUD_CONNECTOR = "cloud.connector";

Method onStartup has a Cognitive Complexity of 50 (exceeds 5 allowed). Consider refactoring.

Open

    @Override
    public void onStartup(ServletContext context) {

        SimpleClassScanner scanner = SimpleClassScanner.getInstance();
        Set<String> packages = scanner.getPackages(false);

• Read up
  Read up

Method toResponse has a Cognitive Complexity of 48 (exceeds 5 allowed). Consider refactoring.

Open

    @Override
    public Response toResponse(Throwable exception) {
        if (template == null) {
            template = util.stream2str(RestExceptionHandler.class.getResourceAsStream(TEMPLATE));
        }

• Read up
  Read up

Method validateCompositePathSyntax has a Cognitive Complexity of 48 (exceeds 5 allowed). Consider refactoring.

Open

    public void validateCompositePathSyntax(String path) {
        Utility util = Utility.getInstance();
        List<String> segments = util.split(path, "./");
        if (segments.isEmpty()) {
            throw new IllegalArgumentException("Missing composite path");

• Read up
  Read up

Method onMessage has a Cognitive Complexity of 48 (exceeds 5 allowed). Consider refactoring.

Open

        @SuppressWarnings("unchecked")
        @Override
        public void onMessage(Message<Map<String, Object>> evt) {
            Utility util = Utility.getInstance();
            PostOffice po = PostOffice.getInstance();

• Read up
  Read up

Method handleEvent has 178 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @Override
    @SuppressWarnings("unchecked")
    public Object handleEvent(Map<String, String> headers, Object body, int instance) throws IOException {
        Platform platform = Platform.getInstance();
        String myOrigin = platform.getOrigin();

Method processEvent has 175 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        @SuppressWarnings({"rawtypes", "unchecked"})
        private ProcessStatus processEvent(EventEnvelope event) {
            ProcessStatus ps = new ProcessStatus();
            PostOffice po = PostOffice.getInstance();
            Map<String, Object> inputOutput = new HashMap<>();

Method handle has a Cognitive Complexity of 44 (exceeds 5 allowed). Consider refactoring.

Open

        @Override
        public void handle(Message<Object> message) {
            Object body = message.body();
            if (body instanceof String) {
                String text = (String) body;

• Read up
  Read up

Method fromMap has a Cognitive Complexity of 44 (exceeds 5 allowed). Consider refactoring.

Open

    @SuppressWarnings("unchecked")
    private void fromMap(Object input) {
        if (input instanceof AsyncHttpRequest) {
            AsyncHttpRequest source = (AsyncHttpRequest) input;
            this.headers = source.headers;

• Read up
  Read up

Method handleEvent has a Cognitive Complexity of 43 (exceeds 5 allowed). Consider refactoring.

Open

    @Override
    public Object handleEvent(Map<String, String> headers, Object body, int instance) throws Exception {
        Utility util = Utility.getInstance();
        PostOffice po = PostOffice.getInstance();
        String myOrigin = Platform.getInstance().getOrigin();

• Read up
  Read up

Method getDestinations has a Cognitive Complexity of 42 (exceeds 5 allowed). Consider refactoring.

Open

    @SuppressWarnings("unchecked")
    private List<String> getDestinations(Map<String, String> headers) {
        String to = headers.get(TO);
        boolean broadcast = headers.containsKey(BROADCAST);
        String id = headers.get(ID);

• Read up
  Read up

Method run has 156 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @Override
    public void run() {
        final boolean requireInitialization = offset == INITIALIZE;
        if (requireInitialization) {
            /*

Method handleEvent has 155 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @Override
    public Object handleEvent(Map<String, String> headers, Object body, int instance) {
        Utility util = Utility.getInstance();
        SimpleHttpUtility httpUtil = SimpleHttpUtility.getInstance();
        EventEnvelope event = (EventEnvelope) body;