skofgar/mercury

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    @SuppressWarnings("unchecked")
    public <T> T getBody(Class<T> toValueType, Class<?>... parameterClass) {
        if (parameterClass.length == 0) {
            throw new IllegalArgumentException("Missing parameter class");
        }

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    @SuppressWarnings("unchecked")
    public <T> T getBody(Class<T> toValueType, Class<?>... parameterClass) {
        if (parameterClass.length == 0) {
            throw new IllegalArgumentException("Missing parameter class");
        }

• Read up
  Read up

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

Open

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

Method checkServices has 47 lines of code (exceeds 25 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) {

Method getTopics has 47 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private List<String> getTopics() throws IOException {
        Utility util = Utility.getInstance();
        PubSub ps = PubSub.getInstance();
        List<String> topics = ps.list();
        if (topics.size() > 1) {

Identical blocks of code found in 2 locations. Consider refactoring.

Open

            for (String address : cluster) {
                int start = address.lastIndexOf('/');
                int colon = address.lastIndexOf(':');
                if (colon > 1 && colon > start) {
                    String host = address.substring(start+1, colon);

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

        this.future = Future.future(p -> {
            this.promise = p;
            this.id = "r."+ Utility.getInstance().getUuid();
            String sender = from == null? ASYNC_INBOX : from;
            this.listener = platform.getEventSystem().localConsumer(this.id, new AsyncMultiInbox.InboxHandler(sender));

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

        this.future = Future.future(p -> {
            this.promise = p;
            this.id = "r."+ Utility.getInstance().getUuid();
            String sender = from == null? ASYNC_INBOX : from;
            this.listener = platform.getEventSystem().localConsumer(this.id, new InboxHandler(sender));

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

            for (String address : cluster) {
                int start = address.lastIndexOf('/');
                int colon = address.lastIndexOf(':');
                if (colon > 1 && colon > start) {
                    String host = address.substring(start+1, colon);

• Read up
  Read up

Method request has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public List<EventEnvelope> request(final List<EventEnvelope> events, long timeout) throws IOException {
        if (events == null || events.isEmpty()) {
            throw new IllegalArgumentException(MISSING_EVENT);
        }
        List<TargetRoute> destinations = new ArrayList<>();

Method asyncRequest has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public Future<List<EventEnvelope>> asyncRequest(final List<EventEnvelope> events, long timeout) throws IOException {
        if (events == null || events.isEmpty()) {
            throw new IllegalArgumentException(MISSING_EVENT);
        }
        List<TargetRoute> destinations = new ArrayList<>();

Method loadServices has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @SuppressWarnings("rawtypes")
    private void loadServices() {
        log.info("Preloading started");
        Utility util = Utility.getInstance();
        Platform platform = Platform.getInstance();

Method readValue has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @SuppressWarnings("unchecked")
    public <T> T readValue(Object fromValue, Class<T> toValueType) {
        if (fromValue == null || toValueType == null) {
            return null;
        }

Method doGet has 45 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @Override
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException {
        if (!ready) {
            response.sendError(404, "Did you forget to do " +
                    "'git clone https://github.com/swagger-api/swagger-ui.git' " +

Similar blocks of code found in 2 locations. Consider refactoring.

Open

/*

    Copyright 2018-2023 Accenture Technology

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

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

/*

    Copyright 2018-2023 Accenture Technology

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

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

            for (EventEnvelope evt: events) {
                n++;
                Map<String, Object> singleResult = new HashMap<>();
                singleResult.put("status", evt.getStatus());
                singleResult.put("headers", evt.getHeaders());

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

        for (EventEnvelope evt: responses) {
            n++;
            Map<String, Object> singleResult = new HashMap<>();
            singleResult.put("status", evt.getStatus());
            singleResult.put("headers", evt.getHeaders());

• Read up
  Read up

Method validateCompositePathSyntax has 44 lines of code (exceeds 25 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");

Method request has 44 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public EventEnvelope request(final EventEnvelope event, long timeout) throws IOException, TimeoutException, AppException {
        if (event == null) {
            throw new IllegalArgumentException(MISSING_EVENT);
        }
        String dest = event.getTo();