public void init()

in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java [352:437]
86 lines of code
1 McCabe index (conditional complexity)

        public void init() {
            put(CommandName.name("PING"), new PingParser());
            put(CommandName.name("REPLCONF"), new ReplConfParser());
            put(CommandName.name("APPEND"), new AppendParser());
            put(CommandName.name("SET"), new SetParser());
            put(CommandName.name("SETEX"), new SetExParser());
            put(CommandName.name("MSET"), new MSetParser());
            put(CommandName.name("DEL"), new DelParser());
            put(CommandName.name("SADD"), new SAddParser());
            put(CommandName.name("HMSET"), new HmSetParser());
            put(CommandName.name("HSET"), new HSetParser());
            put(CommandName.name("LSET"), new LSetParser());
            put(CommandName.name("EXPIRE"), new ExpireParser());
            put(CommandName.name("EXPIREAT"), new ExpireAtParser());
            put(CommandName.name("GETSET"), new GetsetParser());
            put(CommandName.name("HSETNX"), new HSetNxParser());
            put(CommandName.name("MSETNX"), new MSetNxParser());
            put(CommandName.name("PSETEX"), new PSetExParser());
            put(CommandName.name("SETNX"), new SetNxParser());
            put(CommandName.name("SETRANGE"), new SetRangeParser());
            put(CommandName.name("HDEL"), new HDelParser());
            put(CommandName.name("LPOP"), new LPopParser());
            put(CommandName.name("LPUSH"), new LPushParser());
            put(CommandName.name("LPUSHX"), new LPushXParser());
            put(CommandName.name("LRem"), new LRemParser());
            put(CommandName.name("RPOP"), new RPopParser());
            put(CommandName.name("RPUSH"), new RPushParser());
            put(CommandName.name("RPUSHX"), new RPushXParser());
            put(CommandName.name("ZREM"), new ZRemParser());
            put(CommandName.name("RENAME"), new RenameParser());
            put(CommandName.name("INCR"), new IncrParser());
            put(CommandName.name("DECR"), new DecrParser());
            put(CommandName.name("INCRBY"), new IncrByParser());
            put(CommandName.name("DECRBY"), new DecrByParser());
            put(CommandName.name("PERSIST"), new PersistParser());
            put(CommandName.name("SELECT"), new SelectParser());
            put(CommandName.name("FLUSHALL"), new FlushAllParser());
            put(CommandName.name("FLUSHDB"), new FlushDbParser());
            put(CommandName.name("HINCRBY"), new HIncrByParser());
            put(CommandName.name("ZINCRBY"), new ZIncrByParser());
            put(CommandName.name("MOVE"), new MoveParser());
            put(CommandName.name("SMOVE"), new SMoveParser());
            put(CommandName.name("PFADD"), new PfAddParser());
            put(CommandName.name("PFCOUNT"), new PfCountParser());
            put(CommandName.name("PFMERGE"), new PfMergeParser());
            put(CommandName.name("SDIFFSTORE"), new SDiffStoreParser());
            put(CommandName.name("SINTERSTORE"), new SInterStoreParser());
            put(CommandName.name("SUNIONSTORE"), new SUnionStoreParser());
            put(CommandName.name("ZADD"), new ZAddParser());
            put(CommandName.name("ZINTERSTORE"), new ZInterStoreParser());
            put(CommandName.name("ZUNIONSTORE"), new ZUnionStoreParser());
            put(CommandName.name("BRPOPLPUSH"), new BrPopLPushParser());
            put(CommandName.name("LINSERT"), new LinsertParser());
            put(CommandName.name("RENAMENX"), new RenameNxParser());
            put(CommandName.name("RESTORE"), new RestoreParser());
            put(CommandName.name("PEXPIRE"), new PExpireParser());
            put(CommandName.name("PEXPIREAT"), new PExpireAtParser());
            put(CommandName.name("GEOADD"), new GeoAddParser());
            put(CommandName.name("EVAL"), new EvalParser());
            put(CommandName.name("EVALSHA"), new EvalShaParser());
            put(CommandName.name("SCRIPT"), new ScriptParser());
            put(CommandName.name("PUBLISH"), new PublishParser());
            put(CommandName.name("BITOP"), new BitOpParser());
            put(CommandName.name("BITFIELD"), new BitFieldParser());
            put(CommandName.name("SETBIT"), new SetBitParser());
            put(CommandName.name("SREM"), new SRemParser());
            put(CommandName.name("UNLINK"), new UnLinkParser());
            put(CommandName.name("SWAPDB"), new SwapDbParser());
            put(CommandName.name("MULTI"), new MultiParser());
            put(CommandName.name("EXEC"), new ExecParser());
            put(CommandName.name("ZREMRANGEBYSCORE"), new ZRemRangeByScoreParser());
            put(CommandName.name("ZREMRANGEBYRANK"), new ZRemRangeByRankParser());
            put(CommandName.name("ZREMRANGEBYLEX"), new ZRemRangeByLexParser());
            put(CommandName.name("LTRIM"), new LTrimParser());
            put(CommandName.name("SORT"), new SortParser());
            put(CommandName.name("RPOPLPUSH"), new RPopLPushParser());
            put(CommandName.name("ZPOPMIN"), new ZPopMinParser());
            put(CommandName.name("ZPOPMAX"), new ZPopMaxParser());
            put(CommandName.name("XACK"), new XAckParser());
            put(CommandName.name("XADD"), new XAddParser());
            put(CommandName.name("XCLAIM"), new XClaimParser());
            put(CommandName.name("XDEL"), new XDelParser());
            put(CommandName.name("XGROUP"), new XGroupParser());
            put(CommandName.name("XTRIM"), new XTrimParser());
            put(CommandName.name("XSETID"), new XSetIdParser());
        }