openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v6/MessageMarshaller.java [157:192]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutput dataOut, BooleanStream bs) throws IOException { super.tightMarshal2(wireFormat, o, dataOut, bs); Message info = (Message) o; tightMarshalCachedObject2(wireFormat, info.getProducerId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getDestination(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getTransactionId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getOriginalDestination(), dataOut, bs); tightMarshalNestedObject2(wireFormat, info.getMessageId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getOriginalTransactionId(), dataOut, bs); tightMarshalString2(info.getGroupId(), dataOut, bs); dataOut.writeInt(info.getGroupSequence()); tightMarshalString2(info.getCorrelationId(), dataOut, bs); bs.readBoolean(); tightMarshalLong2(wireFormat, info.getExpiration(), dataOut, bs); dataOut.writeByte(info.getPriority()); tightMarshalNestedObject2(wireFormat, info.getReplyTo(), dataOut, bs); tightMarshalLong2(wireFormat, info.getTimestamp(), dataOut, bs); tightMarshalString2(info.getType(), dataOut, bs); tightMarshalByteSequence2(info.getContent(), dataOut, bs); tightMarshalByteSequence2(info.getMarshalledProperties(), dataOut, bs); tightMarshalNestedObject2(wireFormat, info.getDataStructure(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getTargetConsumerId(), dataOut, bs); bs.readBoolean(); dataOut.writeInt(info.getRedeliveryCounter()); tightMarshalObjectArray2(wireFormat, info.getBrokerPath(), dataOut, bs); tightMarshalLong2(wireFormat, info.getArrival(), dataOut, bs); tightMarshalString2(info.getUserId(), dataOut, bs); bs.readBoolean(); bs.readBoolean(); tightMarshalObjectArray2(wireFormat, info.getCluster(), dataOut, bs); tightMarshalLong2(wireFormat, info.getBrokerInTime(), dataOut, bs); tightMarshalLong2(wireFormat, info.getBrokerOutTime(), dataOut, bs); info.afterMarshall(wireFormat); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v8/MessageMarshaller.java [157:192]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutput dataOut, BooleanStream bs) throws IOException { super.tightMarshal2(wireFormat, o, dataOut, bs); Message info = (Message) o; tightMarshalCachedObject2(wireFormat, info.getProducerId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getDestination(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getTransactionId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getOriginalDestination(), dataOut, bs); tightMarshalNestedObject2(wireFormat, info.getMessageId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getOriginalTransactionId(), dataOut, bs); tightMarshalString2(info.getGroupId(), dataOut, bs); dataOut.writeInt(info.getGroupSequence()); tightMarshalString2(info.getCorrelationId(), dataOut, bs); bs.readBoolean(); tightMarshalLong2(wireFormat, info.getExpiration(), dataOut, bs); dataOut.writeByte(info.getPriority()); tightMarshalNestedObject2(wireFormat, info.getReplyTo(), dataOut, bs); tightMarshalLong2(wireFormat, info.getTimestamp(), dataOut, bs); tightMarshalString2(info.getType(), dataOut, bs); tightMarshalByteSequence2(info.getContent(), dataOut, bs); tightMarshalByteSequence2(info.getMarshalledProperties(), dataOut, bs); tightMarshalNestedObject2(wireFormat, info.getDataStructure(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getTargetConsumerId(), dataOut, bs); bs.readBoolean(); dataOut.writeInt(info.getRedeliveryCounter()); tightMarshalObjectArray2(wireFormat, info.getBrokerPath(), dataOut, bs); tightMarshalLong2(wireFormat, info.getArrival(), dataOut, bs); tightMarshalString2(info.getUserId(), dataOut, bs); bs.readBoolean(); bs.readBoolean(); tightMarshalObjectArray2(wireFormat, info.getCluster(), dataOut, bs); tightMarshalLong2(wireFormat, info.getBrokerInTime(), dataOut, bs); tightMarshalLong2(wireFormat, info.getBrokerOutTime(), dataOut, bs); info.afterMarshall(wireFormat); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v9/MessageMarshaller.java [157:192]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutput dataOut, BooleanStream bs) throws IOException { super.tightMarshal2(wireFormat, o, dataOut, bs); Message info = (Message) o; tightMarshalCachedObject2(wireFormat, info.getProducerId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getDestination(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getTransactionId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getOriginalDestination(), dataOut, bs); tightMarshalNestedObject2(wireFormat, info.getMessageId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getOriginalTransactionId(), dataOut, bs); tightMarshalString2(info.getGroupId(), dataOut, bs); dataOut.writeInt(info.getGroupSequence()); tightMarshalString2(info.getCorrelationId(), dataOut, bs); bs.readBoolean(); tightMarshalLong2(wireFormat, info.getExpiration(), dataOut, bs); dataOut.writeByte(info.getPriority()); tightMarshalNestedObject2(wireFormat, info.getReplyTo(), dataOut, bs); tightMarshalLong2(wireFormat, info.getTimestamp(), dataOut, bs); tightMarshalString2(info.getType(), dataOut, bs); tightMarshalByteSequence2(info.getContent(), dataOut, bs); tightMarshalByteSequence2(info.getMarshalledProperties(), dataOut, bs); tightMarshalNestedObject2(wireFormat, info.getDataStructure(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getTargetConsumerId(), dataOut, bs); bs.readBoolean(); dataOut.writeInt(info.getRedeliveryCounter()); tightMarshalObjectArray2(wireFormat, info.getBrokerPath(), dataOut, bs); tightMarshalLong2(wireFormat, info.getArrival(), dataOut, bs); tightMarshalString2(info.getUserId(), dataOut, bs); bs.readBoolean(); bs.readBoolean(); tightMarshalObjectArray2(wireFormat, info.getCluster(), dataOut, bs); tightMarshalLong2(wireFormat, info.getBrokerInTime(), dataOut, bs); tightMarshalLong2(wireFormat, info.getBrokerOutTime(), dataOut, bs); info.afterMarshall(wireFormat); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v7/MessageMarshaller.java [157:192]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutput dataOut, BooleanStream bs) throws IOException { super.tightMarshal2(wireFormat, o, dataOut, bs); Message info = (Message) o; tightMarshalCachedObject2(wireFormat, info.getProducerId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getDestination(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getTransactionId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getOriginalDestination(), dataOut, bs); tightMarshalNestedObject2(wireFormat, info.getMessageId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getOriginalTransactionId(), dataOut, bs); tightMarshalString2(info.getGroupId(), dataOut, bs); dataOut.writeInt(info.getGroupSequence()); tightMarshalString2(info.getCorrelationId(), dataOut, bs); bs.readBoolean(); tightMarshalLong2(wireFormat, info.getExpiration(), dataOut, bs); dataOut.writeByte(info.getPriority()); tightMarshalNestedObject2(wireFormat, info.getReplyTo(), dataOut, bs); tightMarshalLong2(wireFormat, info.getTimestamp(), dataOut, bs); tightMarshalString2(info.getType(), dataOut, bs); tightMarshalByteSequence2(info.getContent(), dataOut, bs); tightMarshalByteSequence2(info.getMarshalledProperties(), dataOut, bs); tightMarshalNestedObject2(wireFormat, info.getDataStructure(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getTargetConsumerId(), dataOut, bs); bs.readBoolean(); dataOut.writeInt(info.getRedeliveryCounter()); tightMarshalObjectArray2(wireFormat, info.getBrokerPath(), dataOut, bs); tightMarshalLong2(wireFormat, info.getArrival(), dataOut, bs); tightMarshalString2(info.getUserId(), dataOut, bs); bs.readBoolean(); bs.readBoolean(); tightMarshalObjectArray2(wireFormat, info.getCluster(), dataOut, bs); tightMarshalLong2(wireFormat, info.getBrokerInTime(), dataOut, bs); tightMarshalLong2(wireFormat, info.getBrokerOutTime(), dataOut, bs); info.afterMarshall(wireFormat); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v5/MessageMarshaller.java [157:192]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutput dataOut, BooleanStream bs) throws IOException { super.tightMarshal2(wireFormat, o, dataOut, bs); Message info = (Message) o; tightMarshalCachedObject2(wireFormat, info.getProducerId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getDestination(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getTransactionId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getOriginalDestination(), dataOut, bs); tightMarshalNestedObject2(wireFormat, info.getMessageId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getOriginalTransactionId(), dataOut, bs); tightMarshalString2(info.getGroupId(), dataOut, bs); dataOut.writeInt(info.getGroupSequence()); tightMarshalString2(info.getCorrelationId(), dataOut, bs); bs.readBoolean(); tightMarshalLong2(wireFormat, info.getExpiration(), dataOut, bs); dataOut.writeByte(info.getPriority()); tightMarshalNestedObject2(wireFormat, info.getReplyTo(), dataOut, bs); tightMarshalLong2(wireFormat, info.getTimestamp(), dataOut, bs); tightMarshalString2(info.getType(), dataOut, bs); tightMarshalByteSequence2(info.getContent(), dataOut, bs); tightMarshalByteSequence2(info.getMarshalledProperties(), dataOut, bs); tightMarshalNestedObject2(wireFormat, info.getDataStructure(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getTargetConsumerId(), dataOut, bs); bs.readBoolean(); dataOut.writeInt(info.getRedeliveryCounter()); tightMarshalObjectArray2(wireFormat, info.getBrokerPath(), dataOut, bs); tightMarshalLong2(wireFormat, info.getArrival(), dataOut, bs); tightMarshalString2(info.getUserId(), dataOut, bs); bs.readBoolean(); bs.readBoolean(); tightMarshalObjectArray2(wireFormat, info.getCluster(), dataOut, bs); tightMarshalLong2(wireFormat, info.getBrokerInTime(), dataOut, bs); tightMarshalLong2(wireFormat, info.getBrokerOutTime(), dataOut, bs); info.afterMarshall(wireFormat); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v4/MessageMarshaller.java [157:192]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutput dataOut, BooleanStream bs) throws IOException { super.tightMarshal2(wireFormat, o, dataOut, bs); Message info = (Message) o; tightMarshalCachedObject2(wireFormat, info.getProducerId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getDestination(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getTransactionId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getOriginalDestination(), dataOut, bs); tightMarshalNestedObject2(wireFormat, info.getMessageId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getOriginalTransactionId(), dataOut, bs); tightMarshalString2(info.getGroupId(), dataOut, bs); dataOut.writeInt(info.getGroupSequence()); tightMarshalString2(info.getCorrelationId(), dataOut, bs); bs.readBoolean(); tightMarshalLong2(wireFormat, info.getExpiration(), dataOut, bs); dataOut.writeByte(info.getPriority()); tightMarshalNestedObject2(wireFormat, info.getReplyTo(), dataOut, bs); tightMarshalLong2(wireFormat, info.getTimestamp(), dataOut, bs); tightMarshalString2(info.getType(), dataOut, bs); tightMarshalByteSequence2(info.getContent(), dataOut, bs); tightMarshalByteSequence2(info.getMarshalledProperties(), dataOut, bs); tightMarshalNestedObject2(wireFormat, info.getDataStructure(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getTargetConsumerId(), dataOut, bs); bs.readBoolean(); dataOut.writeInt(info.getRedeliveryCounter()); tightMarshalObjectArray2(wireFormat, info.getBrokerPath(), dataOut, bs); tightMarshalLong2(wireFormat, info.getArrival(), dataOut, bs); tightMarshalString2(info.getUserId(), dataOut, bs); bs.readBoolean(); bs.readBoolean(); tightMarshalObjectArray2(wireFormat, info.getCluster(), dataOut, bs); tightMarshalLong2(wireFormat, info.getBrokerInTime(), dataOut, bs); tightMarshalLong2(wireFormat, info.getBrokerOutTime(), dataOut, bs); info.afterMarshall(wireFormat); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v3/MessageMarshaller.java [157:192]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void tightMarshal2(OpenWireFormat wireFormat, Object o, DataOutput dataOut, BooleanStream bs) throws IOException { super.tightMarshal2(wireFormat, o, dataOut, bs); Message info = (Message) o; tightMarshalCachedObject2(wireFormat, info.getProducerId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getDestination(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getTransactionId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getOriginalDestination(), dataOut, bs); tightMarshalNestedObject2(wireFormat, info.getMessageId(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getOriginalTransactionId(), dataOut, bs); tightMarshalString2(info.getGroupId(), dataOut, bs); dataOut.writeInt(info.getGroupSequence()); tightMarshalString2(info.getCorrelationId(), dataOut, bs); bs.readBoolean(); tightMarshalLong2(wireFormat, info.getExpiration(), dataOut, bs); dataOut.writeByte(info.getPriority()); tightMarshalNestedObject2(wireFormat, info.getReplyTo(), dataOut, bs); tightMarshalLong2(wireFormat, info.getTimestamp(), dataOut, bs); tightMarshalString2(info.getType(), dataOut, bs); tightMarshalByteSequence2(info.getContent(), dataOut, bs); tightMarshalByteSequence2(info.getMarshalledProperties(), dataOut, bs); tightMarshalNestedObject2(wireFormat, info.getDataStructure(), dataOut, bs); tightMarshalCachedObject2(wireFormat, info.getTargetConsumerId(), dataOut, bs); bs.readBoolean(); dataOut.writeInt(info.getRedeliveryCounter()); tightMarshalObjectArray2(wireFormat, info.getBrokerPath(), dataOut, bs); tightMarshalLong2(wireFormat, info.getArrival(), dataOut, bs); tightMarshalString2(info.getUserId(), dataOut, bs); bs.readBoolean(); bs.readBoolean(); tightMarshalObjectArray2(wireFormat, info.getCluster(), dataOut, bs); tightMarshalLong2(wireFormat, info.getBrokerInTime(), dataOut, bs); tightMarshalLong2(wireFormat, info.getBrokerOutTime(), dataOut, bs); info.afterMarshall(wireFormat); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -