public static AbstractMessage getMessage()

in serializer/seata-serializer-seata/src/main/java/org/apache/seata/serializer/seata/MessageCodecFactory.java [211:307]
95 lines of code
30 McCabe index (conditional complexity)

    public static AbstractMessage getMessage(short typeCode) {
        AbstractMessage abstractMessage = null;
        switch (typeCode) {
            case MessageType.TYPE_SEATA_MERGE:
                abstractMessage = new MergedWarpMessage();
                break;
            case MessageType.TYPE_SEATA_MERGE_RESULT:
                abstractMessage = new MergeResultMessage();
                break;
            case MessageType.TYPE_REG_CLT:
                abstractMessage = new RegisterTMRequest();
                break;
            case MessageType.TYPE_REG_CLT_RESULT:
                abstractMessage = new RegisterTMResponse();
                break;
            case MessageType.TYPE_REG_RM:
                abstractMessage = new RegisterRMRequest();
                break;
            case MessageType.TYPE_REG_RM_RESULT:
                abstractMessage = new RegisterRMResponse();
                break;
            case MessageType.TYPE_BRANCH_COMMIT:
                abstractMessage = new BranchCommitRequest();
                break;
            case MessageType.TYPE_BRANCH_ROLLBACK:
                abstractMessage = new BranchRollbackRequest();
                break;
            case MessageType.TYPE_RM_DELETE_UNDOLOG:
                abstractMessage = new UndoLogDeleteRequest();
                break;
            case MessageType.TYPE_GLOBAL_REPORT:
                abstractMessage = new GlobalReportRequest();
                break;
            case MessageType.TYPE_GLOBAL_REPORT_RESULT:
                abstractMessage = new GlobalReportResponse();
                break;
            case MessageType.TYPE_BATCH_RESULT_MSG:
                abstractMessage = new BatchResultMessage();
                break;
            case MessageType.TYPE_GLOBAL_BEGIN:
                abstractMessage = new GlobalBeginRequest();
                break;
            case MessageType.TYPE_GLOBAL_COMMIT:
                abstractMessage = new GlobalCommitRequest();
                break;
            case MessageType.TYPE_GLOBAL_ROLLBACK:
                abstractMessage = new GlobalRollbackRequest();
                break;
            case MessageType.TYPE_GLOBAL_STATUS:
                abstractMessage = new GlobalStatusRequest();
                break;
            case MessageType.TYPE_GLOBAL_LOCK_QUERY:
                abstractMessage = new GlobalLockQueryRequest();
                break;
            case MessageType.TYPE_BRANCH_REGISTER:
                abstractMessage = new BranchRegisterRequest();
                break;
            case MessageType.TYPE_BRANCH_STATUS_REPORT:
                abstractMessage = new BranchReportRequest();
                break;
            case MessageType.TYPE_GLOBAL_BEGIN_RESULT:
                abstractMessage = new GlobalBeginResponse();
                break;
            case MessageType.TYPE_GLOBAL_COMMIT_RESULT:
                abstractMessage = new GlobalCommitResponse();
                break;
            case MessageType.TYPE_GLOBAL_ROLLBACK_RESULT:
                abstractMessage = new GlobalRollbackResponse();
                break;
            case MessageType.TYPE_GLOBAL_STATUS_RESULT:
                abstractMessage = new GlobalStatusResponse();
                break;
            case MessageType.TYPE_GLOBAL_LOCK_QUERY_RESULT:
                abstractMessage = new GlobalLockQueryResponse();
                break;
            case MessageType.TYPE_BRANCH_REGISTER_RESULT:
                abstractMessage = new BranchRegisterResponse();
                break;
            case MessageType.TYPE_BRANCH_STATUS_REPORT_RESULT:
                abstractMessage = new BranchReportResponse();
                break;
            case MessageType.TYPE_BRANCH_COMMIT_RESULT:
                abstractMessage = new BranchCommitResponse();
                break;
            case MessageType.TYPE_BRANCH_ROLLBACK_RESULT:
                abstractMessage = new BranchRollbackResponse();
                break;
            default:
                break;
        }

        if (abstractMessage != null) {
            return abstractMessage;
        }

        throw new IllegalArgumentException("not support typeCode," + typeCode);
    }