public int tightMarshal1()

in openwire-core/src/main/java/org/apache/activemq/openwire/codec/universal/MessageMarshaller.java [122:168]
44 lines of code
6 McCabe index (conditional complexity)

    public int tightMarshal1(OpenWireFormat wireFormat, Object source, BooleanStream bs) throws IOException {
        Message info = (Message) source;
        int version = wireFormat.getVersion();

        info.beforeMarshall(wireFormat);

        int rc = super.tightMarshal1(wireFormat, source, bs);
        rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getProducerId(), bs);
        rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getDestination(), bs);
        rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getTransactionId(), bs);
        rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getOriginalDestination(), bs);
        rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getMessageId(), bs);
        rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getOriginalTransactionId(), bs);
        rc += tightMarshalString1(info.getGroupId(), bs);
        rc += tightMarshalString1(info.getCorrelationId(), bs);
        bs.writeBoolean(info.isPersistent());
        rc += tightMarshalLong1(wireFormat, info.getExpiration(), bs);
        rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getReplyTo(), bs);
        rc += tightMarshalLong1(wireFormat, info.getTimestamp(), bs);
        rc += tightMarshalString1(info.getType(), bs);
        rc += tightMarshalByteSequence1(info.getContent(), bs);
        rc += tightMarshalByteSequence1(info.getMarshalledProperties(), bs);
        rc += tightMarshalNestedObject1(wireFormat, (DataStructure)info.getDataStructure(), bs);
        rc += tightMarshalCachedObject1(wireFormat, (DataStructure)info.getTargetConsumerId(), bs);
        bs.writeBoolean(info.isCompressed());
        rc += tightMarshalObjectArray1(wireFormat, info.getBrokerPath(), bs);
        rc += tightMarshalLong1(wireFormat, info.getArrival(), bs);
        rc += tightMarshalString1(info.getUserId(), bs);
        bs.writeBoolean(info.isRecievedByDFBridge());
        if (version >= 2) {
            bs.writeBoolean(info.isDroppable());
        }
        if (version >= 3) {
            rc += tightMarshalObjectArray1(wireFormat, info.getCluster(), bs);
        }
        if (version >= 3) {
            rc += tightMarshalLong1(wireFormat, info.getBrokerInTime(), bs);
        }
        if (version >= 3) {
            rc += tightMarshalLong1(wireFormat, info.getBrokerOutTime(), bs);
        }
        if (version >= 10) {
            bs.writeBoolean(info.isJMSXGroupFirstForConsumer());
        }

        return rc + 9;
    }