Method fromMap has 85 lines of code (exceeds 25 allowed). Consider refactoring.

Open

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

Method onMessage has 84 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        @SuppressWarnings("unchecked")
        @Override
        public void onMessage(Message evt) {
            PostOffice po = PostOffice.getInstance();
            String origin = Platform.getInstance().getOrigin();

Method onMessage has 84 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        @SuppressWarnings("unchecked")
        @Override
        public void onMessage(Message evt) {
            PostOffice po = PostOffice.getInstance();
            String origin = Platform.getInstance().getOrigin();

Method startHttpServerIfAny has 83 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private void startHttpServerIfAny() throws IOException, InterruptedException {
        // find and execute optional preparation modules
        SimpleClassScanner scanner = SimpleClassScanner.getInstance();
        Set<String> packages = scanner.getPackages(true);
        for (String p : packages) {

Method getUrl has a Cognitive Complexity of 23 (exceeds 5 allowed). Consider refactoring.

Open

    private String getUrl(String url, boolean exact) {
        StringBuilder sb = new StringBuilder();
        List<String> parts = Utility.getInstance().split(url.toLowerCase(), "/");
        for (String p: parts) {
            String s = p.trim();

• Read up
  Read up

Method scanLibInfo has a Cognitive Complexity of 23 (exceeds 5 allowed). Consider refactoring.

Open

    private void scanLibInfo() {
        if (!loaded) {
            synchronized (ORDERLY_SCAN) {
                List<String> list = new ArrayList<>();
                for (String r : JAR_PATHS) {

• Read up
  Read up

Method stream2bytes has a Cognitive Complexity of 23 (exceeds 5 allowed). Consider refactoring.

Open

    public byte[] stream2bytes(InputStream stream, boolean closeStream, int maxSize) {
        if (stream == null) {
            return new byte[0];
        }
        ByteArrayOutputStream out = new ByteArrayOutputStream();

• Read up
  Read up

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

Open

    @Override
    public Object handleEvent(Map<String, String> headers, Object body, int instance) throws IOException {
        if (headers.containsKey(TYPE)) {
            if (LIST.equals(headers.get(TYPE))) {
                return listTopics();

• Read up
  Read up

Method checkServices has a Cognitive Complexity of 23 (exceeds 5 allowed). Consider refactoring.

Open

    @SuppressWarnings("unchecked")
    private boolean checkServices(List<Map<String, Object>> upstream, List<String> healthServices, boolean required) {
        PostOffice po = PostOffice.getInstance();
        boolean up = true;
        for (String route: healthServices) {

• Read up
  Read up

Method getNextAvailable has a Cognitive Complexity of 23 (exceeds 5 allowed). Consider refactoring.

Open

    private String getNextAvailable(List<String> targetList) {
        List<String> available = new ArrayList<>();
        for (String target: targetList) {
            if (ServiceRegistry.destinationExists(target)) {
                available.add(target);

• Read up
  Read up

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

Open

    @Override
    @SuppressWarnings("unchecked")
    public Object handleEvent(Map<String, String> headers, Object body, int instance) throws Exception {
        if (INFO.equals(headers.get(TYPE))) {
            Map<String, Object> result = new HashMap<>();

• Read up
  Read up

Platform has 27 methods (exceeds 20 allowed). Consider refactoring.

Open

public class Platform {
    private static final Logger log = LoggerFactory.getLogger(Platform.class);
    private static final ManagedCache cache = ManagedCache.createCache("system.log.cache", 30000);
    private static final CryptoApi crypto = new CryptoApi();
    private static final ConcurrentMap<String, BlockingQueue<Boolean>> serviceTokens = new ConcurrentHashMap<>();

Method handle has 79 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @Override
    public void handle(HttpServerRequest request) {
        PostOffice po = PostOffice.getInstance();
        Utility util = Utility.getInstance();
        HttpServerResponse response = request.response();

File MonitorService.java has 298 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/*

    Copyright 2018-2023 Accenture Technology

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

Method sendRequestToService has a Cognitive Complexity of 22 (exceeds 5 allowed). Consider refactoring.

Open

    public void sendRequestToService(HttpServerRequest request, HttpRequestEvent requestEvent) {
        SimpleHttpUtility httpUtil = SimpleHttpUtility.getInstance();
        PostOffice po = PostOffice.getInstance();
        if (requestEvent.authService != null) {
            try {

• Read up
  Read up

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

Open

    @Override
    public void handle(HttpServerRequest request) {
        PostOffice po = PostOffice.getInstance();
        Utility util = Utility.getInstance();
        HttpServerResponse response = request.response();

• Read up
  Read up

Method getTibcoProperties has a Cognitive Complexity of 22 (exceeds 5 allowed). Consider refactoring.

Open

    public static synchronized Properties getTibcoProperties(String location) {
        // default location is cloud.client.properties
        Properties properties = allProperties.get(location);
        if (properties == null) {
            properties = new Properties();

• Read up
  Read up

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

Open

    @Override
    public Object handleEvent(Map<String, String> headers, Object body, int instance) throws Exception {
        if (headers.containsKey(TYPE)) {
            String type = headers.get(TYPE);
            if (LIVENESS_PROBE.equals(type)) {

• Read up
  Read up

Method getClusterProperties has a Cognitive Complexity of 22 (exceeds 5 allowed). Consider refactoring.

Open

    public static Properties getClusterProperties(String location) {
        // default location is cloud.client.properties
        Properties properties = allProperties.get(location);
        if (properties == null) {
            ConfigReader clusterConfig = null;

• Read up
  Read up

File PubSubManager.java has 295 lines of code (exceeds 250 allowed). Consider refactoring.

Open

/*

    Copyright 2018-2023 Accenture Technology

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