skofgar/mercury

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

Open

    @Override
    public Object handleEvent(Map<String, String> headers, Object body, int instance) throws Exception {
        if (headers.containsKey(TO) && body instanceof byte[]) {
            List<String> destinations = getDestinations(headers);
            if (!destinations.isEmpty()) {

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

Open

    @Override
    public int partitionCount(String topic) throws IOException {
        try {
            EventEnvelope response = PostOffice.getInstance().request(cloudManager, 20000,
                    new Kv(TYPE, PARTITIONS), new Kv(TOPIC, topic));

• Read up
  Read up

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

Open

    @Override
    public int partitionCount(String topic) throws IOException {
        try {
            EventEnvelope response = PostOffice.getInstance().request(cloudManager, 20000,
                                        new Kv(TYPE, PARTITIONS), new Kv(TOPIC, topic));

• Read up
  Read up

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

Open

    @Override
    public int partitionCount(String topic) throws IOException {
        try {
            EventEnvelope response = PostOffice.getInstance().request(cloudManager, 20000,
                    new Kv(TYPE, PARTITIONS), new Kv(TOPIC, topic));

• Read up
  Read up

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

Open

    @Override
    public int partitionCount(String topic) throws IOException {
        try {
            EventEnvelope response = PostOffice.getInstance().request(cloudManager, 20000,
                    new Kv(TYPE, PARTITIONS), new Kv(TOPIC, topic));

• Read up
  Read up

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

Open

            connection.setExceptionListener((e) -> {
                String error = e.getMessage();
                log.error("Activemq cluster exception - {}", error);
                if (error != null && (error.contains("terminated") || error.contains("disconnect"))) {
                    ArtemisConnector.stopConnection(domain);

• Read up
  Read up

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

Open

            connection.setExceptionListener((e) -> {
                String error = e.getMessage();
                log.error("Tibco cluster exception - {}", error);
                if (error != null && (error.contains("terminated") || error.contains("disconnect"))) {
                    TibcoConnector.stopConnection(domain);

• Read up
  Read up

Method getRouteInfo has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public AssignedRoute getRouteInfo(String method, String url) {
        Utility util = Utility.getInstance();
        StringBuilder sb = new StringBuilder();
        List<String> input = util.split(url, "/");
        for (String p: input) {

Method register has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @SuppressWarnings("rawtypes")
    private void register(String route, TypedLambdaFunction lambda, boolean isPrivate, int instances)
            throws IOException {
        if (lambda == null) {
            throw new IOException("Missing lambda function");

Method loadMulticast has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @SuppressWarnings("unchecked")
    private void loadMulticast(Map<String, Object> map) {
        Set<String> list = new HashSet<>();
        Platform platform = Platform.getInstance();
        MultiLevelMap multi = new MultiLevelMap(map);

Method suspendResume has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private void suspendResume(HttpServerResponse response, String uri, String origin) {
        if (origin == null) {
            sendError(response, uri, 400, "Missing "+ APP_INSTANCE +" in request header");
            return;
        }

Method getBody has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @SuppressWarnings("unchecked")
    public Object getBody() {
        if (!encoded) {
            if (type == null) {
                setBody(body);

Method registerStream has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private void registerStream(String route, StreamFunction lambda, boolean isPrivate) throws IOException {
        if (lambda == null) {
            throw new IOException("Missing lambda function");
        }
        String path = getValidatedRoute(route);

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

Open

        @Override
        public Object handleEvent(Map<String, String> headers, Object body, int instance) {
            if (body instanceof String && db != null && dbEnv != null) {
                Utility util = Utility.getInstance();
                int n = 0;

Method getClient has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public static synchronized HazelcastInstance getClient(String domain, Properties properties) {
        HazelcastInstance client = allClients.get(domain);
        if (client == null) {
            Utility util = Utility.getInstance();
            String url = properties.getProperty(BROKER_URL);

Method getReplicationFactor has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private int getReplicationFactor() {
        if (topicSubstitution) {
            return 1;
        }
        if (replicationFactor == -1) {

Method topicPartitions has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private int topicPartitions(String topic) throws TibjmsAdminException {
        if (topicSubstitution) {
            int n = 0;
            while (preAllocatedTopics.containsKey(topic+"."+n)) {
                n++;

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

Open

    @Override
    public boolean exists(String topic) throws IOException {
        try {
            EventEnvelope response = PostOffice.getInstance().request(cloudManager, 20000,
                    new Kv(TYPE, EXISTS), new Kv(TOPIC, topic));

• Read up
  Read up

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

Open

            if (CREATE.equals(headers.get(TYPE)) && headers.containsKey(TOPIC)) {
                int partitions = headers.containsKey(PARTITIONS)?
                                    Math.max(1, Utility.getInstance().str2int(headers.get(PARTITIONS))) : 1;
                createTopic(headers.get(TOPIC), partitions);
                return true;

• Read up
  Read up

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

Open

            if (value == null) {
                v = "";
            } else if (value instanceof String) {
                v = (String) value;
            } else if (value instanceof Date) {

• Read up
  Read up