public static MessageSeataCodec getMessageCodec()

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

    public static MessageSeataCodec getMessageCodec(short typeCode, byte version) {
        MessageSeataCodec msgCodec = null;
        switch (typeCode) {
            case MessageType.TYPE_SEATA_MERGE:
                msgCodec = new MergedWarpMessageCodec(version);
                break;
            case MessageType.TYPE_SEATA_MERGE_RESULT:
                msgCodec = new MergeResultMessageCodec(version);
                break;
            case MessageType.TYPE_REG_CLT:
                msgCodec = new RegisterTMRequestCodec();
                break;
            case MessageType.TYPE_REG_CLT_RESULT:
                msgCodec = new RegisterTMResponseCodec();
                break;
            case MessageType.TYPE_REG_RM:
                msgCodec = new RegisterRMRequestCodec();
                break;
            case MessageType.TYPE_REG_RM_RESULT:
                msgCodec = new RegisterRMResponseCodec();
                break;
            case MessageType.TYPE_BRANCH_COMMIT:
                msgCodec = new BranchCommitRequestCodec();
                break;
            case MessageType.TYPE_BRANCH_ROLLBACK:
                msgCodec = new BranchRollbackRequestCodec();
                break;
            case MessageType.TYPE_GLOBAL_REPORT:
                msgCodec = new GlobalReportRequestCodec();
                break;
            case MessageType.TYPE_BATCH_RESULT_MSG:
                msgCodec = new BatchResultMessageCodec(version);
                break;
            case MessageType.TYPE_GLOBAL_BEGIN:
                msgCodec = new GlobalBeginRequestCodec();
                break;
            case MessageType.TYPE_GLOBAL_COMMIT:
                msgCodec = new GlobalCommitRequestCodec();
                break;
            case MessageType.TYPE_GLOBAL_ROLLBACK:
                msgCodec = new GlobalRollbackRequestCodec();
                break;
            case MessageType.TYPE_GLOBAL_STATUS:
                msgCodec = new GlobalStatusRequestCodec();
                break;
            case MessageType.TYPE_GLOBAL_LOCK_QUERY:
                msgCodec = new GlobalLockQueryRequestCodec();
                break;
            case MessageType.TYPE_BRANCH_REGISTER:
                msgCodec = new BranchRegisterRequestCodec();
                break;
            case MessageType.TYPE_BRANCH_STATUS_REPORT:
                msgCodec = new BranchReportRequestCodec();
                break;
            case MessageType.TYPE_GLOBAL_BEGIN_RESULT:
                msgCodec = new GlobalBeginResponseCodec();
                break;
            case MessageType.TYPE_GLOBAL_COMMIT_RESULT:
                msgCodec = new GlobalCommitResponseCodec();
                break;
            case MessageType.TYPE_GLOBAL_ROLLBACK_RESULT:
                msgCodec = new GlobalRollbackResponseCodec();
                break;
            case MessageType.TYPE_GLOBAL_STATUS_RESULT:
                msgCodec = new GlobalStatusResponseCodec();
                break;
            case MessageType.TYPE_GLOBAL_LOCK_QUERY_RESULT:
                msgCodec = new GlobalLockQueryResponseCodec();
                break;
            case MessageType.TYPE_BRANCH_REGISTER_RESULT:
                msgCodec = new BranchRegisterResponseCodec();
                break;
            case MessageType.TYPE_BRANCH_STATUS_REPORT_RESULT:
                msgCodec = new BranchReportResponseCodec();
                break;
            case MessageType.TYPE_BRANCH_COMMIT_RESULT:
                msgCodec = new BranchCommitResponseCodec();
                break;
            case MessageType.TYPE_BRANCH_ROLLBACK_RESULT:
                msgCodec = new BranchRollbackResponseCodec();
                break;
            case MessageType.TYPE_RM_DELETE_UNDOLOG:
                msgCodec = new UndoLogDeleteRequestCodec();
                break;
            case MessageType.TYPE_GLOBAL_REPORT_RESULT:
                msgCodec = new GlobalReportResponseCodec();
                break;
            default:
                break;
        }

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

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