public void looseUnmarshal()

in openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/MessageMarshaller.java [293:360]
65 lines of code
10 McCabe index (conditional complexity)

    public void looseUnmarshal(OpenWireFormat wireFormat, Object target, DataInput dataIn) throws IOException {
        super.looseUnmarshal(wireFormat, target, dataIn);

        Message info = (Message) target;
        int version = wireFormat.getVersion();

        info.beforeUnmarshall(wireFormat);
        info.setProducerId((ProducerId) looseUnmarsalCachedObject(wireFormat, dataIn));
        info.setDestination((OpenWireDestination) looseUnmarsalCachedObject(wireFormat, dataIn));
        info.setTransactionId((TransactionId) looseUnmarsalCachedObject(wireFormat, dataIn));
        info.setOriginalDestination((OpenWireDestination) looseUnmarsalCachedObject(wireFormat, dataIn));
        info.setMessageId((MessageId) looseUnmarsalNestedObject(wireFormat, dataIn));
        info.setOriginalTransactionId((TransactionId) looseUnmarsalCachedObject(wireFormat, dataIn));
        info.setGroupID(looseUnmarshalString(dataIn));
        info.setGroupSequence(dataIn.readInt());
        info.setCorrelationId(looseUnmarshalString(dataIn));
        info.setPersistent(dataIn.readBoolean());
        info.setExpiration(looseUnmarshalLong(wireFormat, dataIn));
        info.setPriority(dataIn.readByte());
        info.setReplyTo((OpenWireDestination) looseUnmarsalNestedObject(wireFormat, dataIn));
        info.setTimestamp(looseUnmarshalLong(wireFormat, dataIn));
        info.setType(looseUnmarshalString(dataIn));
        info.setContent(looseUnmarshalByteSequence(dataIn));
        info.setMarshalledProperties(looseUnmarshalByteSequence(dataIn));
        info.setDataStructure((DataStructure) looseUnmarsalNestedObject(wireFormat, dataIn));
        info.setTargetConsumerId((ConsumerId) looseUnmarsalCachedObject(wireFormat, dataIn));
        info.setCompressed(dataIn.readBoolean());
        info.setRedeliveryCounter(dataIn.readInt());
        if (dataIn.readBoolean()) {
            short size = dataIn.readShort();
            BrokerId value[] = new BrokerId[size];
            for (int i = 0; i < size; i++) {
                value[i] = (BrokerId) looseUnmarsalNestedObject(wireFormat,dataIn);
            }
            info.setBrokerPath(value);
        } else {
            info.setBrokerPath(null);
        }
        info.setArrival(looseUnmarshalLong(wireFormat, dataIn));
        info.setUserId(looseUnmarshalString(dataIn));
        info.setRecievedByDFBridge(dataIn.readBoolean());
        if (version >= 2) {
            info.setDroppable(dataIn.readBoolean());
        }
        if (version >= 3) {
            if (dataIn.readBoolean()) {
                short size = dataIn.readShort();
                BrokerId value[] = new BrokerId[size];
                for (int i = 0; i < size; i++) {
                    value[i] = (BrokerId) looseUnmarsalNestedObject(wireFormat,dataIn);
                }
                info.setCluster(value);
            } else {
                info.setCluster(null);
            }
        }
        if (version >= 3) {
            info.setBrokerInTime(looseUnmarshalLong(wireFormat, dataIn));
        }
        if (version >= 3) {
            info.setBrokerOutTime(looseUnmarshalLong(wireFormat, dataIn));
        }
        if (version >= 10) {
            info.setJMSXGroupFirstForConsumer(dataIn.readBoolean());
        }

        info.afterUnmarshall(wireFormat);
    }