this.processMessage = function()

in shims/rhea-js/amqp_types_test/Receiver.js [51:80]

• 30 lines of code
• 25 McCabe index (conditional complexity)

    this.processMessage = function(msgBody) {
//        console.log("processMessage: amqpType=" + this.amqpType + "; msgBody=" + msgBody);
        switch(this.amqpType) {
        case "null": this.receivedValueList.push(this.decodeNull(msgBody)); break;
        case "boolean": this.receivedValueList.push(this.decodeBoolean(msgBody)); break;
        case "ubyte":
        case "ushort":
        case "uint":
        case "ulong":
        case "decimal32":
        case "decimal64":
        case "decimal128": this.receivedValueList.push(this.decodeUnsigned(msgBody)); break;
        case "timestamp": this.receivedValueList.push(this.decodeTimestamp(msgBody)); break;
        case "byte":
        case "short":
        case "int":
        case "long": this.receivedValueList.push(this.decodeSigned(msgBody)); break;
        case "float": this.receivedValueList.push(this.decodeFloat(msgBody)); break;
        case "double": this.receivedValueList.push(this.decodeDouble(msgBody)); break;
        case "char": this.receivedValueList.push(this.decodeChar(msgBody)); break;
        case "uuid": this.receivedValueList.push(this.decodeUuid(msgBody)); break;
        case "binary": this.receivedValueList.push(this.decodeBinary(msgBody)); break;
        case "string": this.receivedValueList.push(this.decodeString(msgBody)); break;
        case "symbol": this.receivedValueList.push(this.decodeSymbol(msgBody)); break;
        case "list":
        case "map":
        case "array": throw "Unsupported complex AMQP type: \"" + this.amqpType + "\"";
        default: throw "Unknown AMQP type: " + this.amqpType;
        }
    };