skofgar/mercury

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

Open

        @Override
        public Object handleEvent(Map<String, String> headers, Object body, int instance) throws Exception {
            Platform platform = Platform.getInstance();
            PostOffice po = PostOffice.getInstance();
            EventEnvelope event = (EventEnvelope) body;

Method executeOrderly has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private void executeOrderly(Map<String, Class<?>> steps, String[] args, boolean main) {
        List<String> list = new ArrayList<>(steps.keySet());
        if (list.size() > 1) {
            Collections.sort(list);
        }

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

Open

    public Future<EventEnvelope> asyncRequest(final EventEnvelope event, long timeout) throws IOException {
        if (event == null) {
            throw new IllegalArgumentException(MISSING_EVENT);
        }
        String dest = event.getTo();

Method sendLater has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public String sendLater(final EventEnvelope event, Date future) {
        String dest = event.getTo();
        if (dest == null) {
            throw new IllegalArgumentException(MISSING_ROUTING_PATH);
        }

Method escapeXml has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private String escapeXml(String value, TagType type) {
        switch (type) {
            case START:
                if (value.startsWith("/") || value.startsWith("{")) {
                    return "node value=\""+value+"\"";

Method sendEvent has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private void sendEvent(String topic, int partition, Map<String, String> headers, Object body) {
        String realTopic = partition < 0 ? topic : topic + "." + partition;
        if (ConnectorConfig.topicSubstitutionEnabled()) {
            realTopic = preAllocatedTopics.getOrDefault(realTopic, realTopic);
        }

Method transform has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private Map<String, Object> transform(Map<String, String> headers) {
        // restore the original types for selected key-values
        Utility util = Utility.getInstance();
        Map<String, Object> result = new HashMap<>();
        for (String key: headers.keySet()) {

Method publish has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @Override
    public void publish(String topic, int partition, Map<String, String> headers, Object body) throws IOException {
        ConnectorConfig.validateTopicName(topic);
        Map<String, String> eventHeaders = headers == null? new HashMap<>() : headers;
        if (eventHeaders.containsKey(EventProducer.EMBED_EVENT) && body instanceof byte[]) {

Method handleEvent has 30 lines of code (exceeds 25 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();

Method sendEvent has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    private void sendEvent(String topic, int partition, Map<String, String> headers, Object body) {
        String realTopic = partition < 0 ? topic : topic + "." + partition;
        if (ConnectorConfig.topicSubstitutionEnabled()) {
            realTopic = preAllocatedTopics.getOrDefault(realTopic, realTopic);
        }

Method publish has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @Override
    public void publish(String topic, int partition, Map<String, String> headers, Object body) throws IOException {
        ConnectorConfig.validateTopicName(topic);
        Map<String, String> eventHeaders = headers == null? new HashMap<>() : headers;
        if (eventHeaders.containsKey(EventProducer.EMBED_EVENT) && body instanceof byte[]) {

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

Open

            for (EventEnvelope event : events) {
                TargetRoute target = destinations.get(n++);
                event.setBroadcastLevel(0);
                event.setReplyTo(replyTo);
                if (target.isCloud()) {

• Read up
  Read up

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

Open

                            if (EventProducer.TEXT_DATA.equals(dataType)) {
                                message.setHeaders(originalHeaders).setBody(util.getUTF(data));
                            } else if (EventProducer.MAP_DATA.equals(dataType) ||
                                    EventProducer.LIST_DATA.equals(dataType)) {
                                message.setHeaders(originalHeaders).setBody(msgPack.unpack(data));

• Read up
  Read up

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

Open

        for (EventEnvelope event : events) {
            TargetRoute target = destinations.get(n++);
            event.setBroadcastLevel(0);
            event.setReplyTo(replyTo);
            if (target.isCloud()) {

• Read up
  Read up

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

Open

                        if (EventProducer.TEXT_DATA.equals(dataType)) {
                            message.setHeaders(originalHeaders).setBody(util.getUTF(data));
                        } else if (EventProducer.MAP_DATA.equals(dataType) || EventProducer.LIST_DATA.equals(dataType)) {
                            message.setHeaders(originalHeaders).setBody(msgPack.unpack(data));
                        } else {

• Read up
  Read up

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

Open

    public long str2long(String str) {
        if (str == null || str.length() == 0) {
            return -1;
        }
        try {

• Read up
  Read up

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

Open

    public int str2int(String str) {
        if (str == null || str.length() == 0) {
            return -1;
        }
        try {

• Read up
  Read up

Method startCloudServices has 29 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public synchronized void startCloudServices() {
        if (!Platform.cloudServicesStarted) {
            // guarantee to execute once
            Platform.cloudServicesStarted = true;
            AppConfigReader reader = AppConfigReader.getInstance();

Method validateServiceList has 29 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    @SuppressWarnings("unchecked")
    private List<String> validateServiceList(Object svcList) {
        Utility util = Utility.getInstance();
        List<String> list = svcList instanceof String?
                Collections.singletonList((String) svcList) : (List<String>) svcList;

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

Open

        if (trace != null) {
            if (trace.route != null && event.getFrom() == null) {
                event.setFrom(trace.route);
            }
            if (trace.id != null && trace.path != null) {

• Read up
  Read up