private boolean preHandler()

in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/MqttPacketDispatcher.java [182:207]

• 26 lines of code
• 11 McCabe index (conditional complexity)

    private boolean preHandler(ChannelHandlerContext ctx, MqttMessage msg) {
        switch (msg.fixedHeader().messageType()) {
            case CONNECT:
                return mqttConnectHandler.preHandler(ctx, (MqttConnectMessage) msg);
            case PUBLISH:
                return mqttPublishHandler.preHandler(ctx, (MqttPublishMessage) msg);
            case SUBSCRIBE:
                return mqttSubscribeHandler.preHandler(ctx, (MqttSubscribeMessage) msg);
            case PUBACK:
                return mqttPubAckHandler.preHandler(ctx, (MqttPubAckMessage) msg);
            case PINGREQ:
                return mqttPingHandler.preHandler(ctx, msg);
            case UNSUBSCRIBE:
                return mqttUnSubscribeHandler.preHandler(ctx, (MqttUnsubscribeMessage) msg);
            case PUBREL:
                return mqttPubRelHandler.preHandler(ctx, msg);
            case PUBREC:
                return mqttPubRecHandler.preHandler(ctx, msg);
            case PUBCOMP:
                return mqttPubCompHandler.preHandler(ctx, msg);
            case DISCONNECT:
                return mqttDisconnectHandler.preHandler(ctx, msg);
            default:
                return true;
        }
    }