RedisMessage() — netty Function Reference

Architecture documentation for the RedisMessage() function in RedisDecoder.java from the netty codebase.

Function java Buffer Allocators calls 1

Entity Profile

Buffer→ Allocators→ RedisMessage() — netty Function Reference

Dependency Diagram

graph TD
  ed1d2f76_8564_f576_4432_ddafa832113c["RedisMessage()"]
  2421b439_cffa_67ca_b872_bb582dd0dbf2["RedisDecoder"]
  ed1d2f76_8564_f576_4432_ddafa832113c -->|defined in| 2421b439_cffa_67ca_b872_bb582dd0dbf2
  24e865f9_bdd6_9dd8_56dc_9edb5828f082["parseRedisNumber()"]
  ed1d2f76_8564_f576_4432_ddafa832113c -->|calls| 24e865f9_bdd6_9dd8_56dc_9edb5828f082
  style ed1d2f76_8564_f576_4432_ddafa832113c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

codec-redis/src/main/java/io/netty/handler/codec/redis/RedisDecoder.java lines 255–274

    private RedisMessage newInlineRedisMessage(RedisMessageType messageType, ByteBuf content) {
        switch (messageType) {
        case INLINE_COMMAND:
            return new InlineCommandRedisMessage(content.toString(CharsetUtil.UTF_8));
        case SIMPLE_STRING: {
            SimpleStringRedisMessage cached = messagePool.getSimpleString(content);
            return cached != null ? cached : new SimpleStringRedisMessage(content.toString(CharsetUtil.UTF_8));
        }
        case ERROR: {
            ErrorRedisMessage cached = messagePool.getError(content);
            return cached != null ? cached : new ErrorRedisMessage(content.toString(CharsetUtil.UTF_8));
        }
        case INTEGER: {
            IntegerRedisMessage cached = messagePool.getInteger(content);
            return cached != null ? cached : new IntegerRedisMessage(parseRedisNumber(content));
        }
        default:
            throw new RedisCodecException("bad type: " + messageType);
        }
    }