openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v6/MessageMarshaller.java [109:144]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException { Message info = (Message) o; info.beforeMarshall(wireFormat); int rc = super.tightMarshal1(wireFormat, o, bs); rc += tightMarshalCachedObject1(wireFormat, info.getProducerId(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getDestination(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getTransactionId(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getOriginalDestination(), bs); rc += tightMarshalNestedObject1(wireFormat, info.getMessageId(), bs); rc += tightMarshalCachedObject1(wireFormat, 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, 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, info.getDataStructure(), bs); rc += tightMarshalCachedObject1(wireFormat, 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()); bs.writeBoolean(info.isDroppable()); rc += tightMarshalObjectArray1(wireFormat, info.getCluster(), bs); rc += tightMarshalLong1(wireFormat, info.getBrokerInTime(), bs); rc += tightMarshalLong1(wireFormat, info.getBrokerOutTime(), bs); return rc + 9; } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v8/MessageMarshaller.java [109:144]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException { Message info = (Message) o; info.beforeMarshall(wireFormat); int rc = super.tightMarshal1(wireFormat, o, bs); rc += tightMarshalCachedObject1(wireFormat, info.getProducerId(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getDestination(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getTransactionId(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getOriginalDestination(), bs); rc += tightMarshalNestedObject1(wireFormat, info.getMessageId(), bs); rc += tightMarshalCachedObject1(wireFormat, 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, 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, info.getDataStructure(), bs); rc += tightMarshalCachedObject1(wireFormat, 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()); bs.writeBoolean(info.isDroppable()); rc += tightMarshalObjectArray1(wireFormat, info.getCluster(), bs); rc += tightMarshalLong1(wireFormat, info.getBrokerInTime(), bs); rc += tightMarshalLong1(wireFormat, info.getBrokerOutTime(), bs); return rc + 9; } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v9/MessageMarshaller.java [109:144]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException { Message info = (Message) o; info.beforeMarshall(wireFormat); int rc = super.tightMarshal1(wireFormat, o, bs); rc += tightMarshalCachedObject1(wireFormat, info.getProducerId(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getDestination(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getTransactionId(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getOriginalDestination(), bs); rc += tightMarshalNestedObject1(wireFormat, info.getMessageId(), bs); rc += tightMarshalCachedObject1(wireFormat, 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, 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, info.getDataStructure(), bs); rc += tightMarshalCachedObject1(wireFormat, 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()); bs.writeBoolean(info.isDroppable()); rc += tightMarshalObjectArray1(wireFormat, info.getCluster(), bs); rc += tightMarshalLong1(wireFormat, info.getBrokerInTime(), bs); rc += tightMarshalLong1(wireFormat, info.getBrokerOutTime(), bs); return rc + 9; } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v7/MessageMarshaller.java [109:144]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException { Message info = (Message) o; info.beforeMarshall(wireFormat); int rc = super.tightMarshal1(wireFormat, o, bs); rc += tightMarshalCachedObject1(wireFormat, info.getProducerId(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getDestination(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getTransactionId(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getOriginalDestination(), bs); rc += tightMarshalNestedObject1(wireFormat, info.getMessageId(), bs); rc += tightMarshalCachedObject1(wireFormat, 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, 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, info.getDataStructure(), bs); rc += tightMarshalCachedObject1(wireFormat, 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()); bs.writeBoolean(info.isDroppable()); rc += tightMarshalObjectArray1(wireFormat, info.getCluster(), bs); rc += tightMarshalLong1(wireFormat, info.getBrokerInTime(), bs); rc += tightMarshalLong1(wireFormat, info.getBrokerOutTime(), bs); return rc + 9; } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v5/MessageMarshaller.java [109:144]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException { Message info = (Message) o; info.beforeMarshall(wireFormat); int rc = super.tightMarshal1(wireFormat, o, bs); rc += tightMarshalCachedObject1(wireFormat, info.getProducerId(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getDestination(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getTransactionId(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getOriginalDestination(), bs); rc += tightMarshalNestedObject1(wireFormat, info.getMessageId(), bs); rc += tightMarshalCachedObject1(wireFormat, 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, 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, info.getDataStructure(), bs); rc += tightMarshalCachedObject1(wireFormat, 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()); bs.writeBoolean(info.isDroppable()); rc += tightMarshalObjectArray1(wireFormat, info.getCluster(), bs); rc += tightMarshalLong1(wireFormat, info.getBrokerInTime(), bs); rc += tightMarshalLong1(wireFormat, info.getBrokerOutTime(), bs); return rc + 9; } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v4/MessageMarshaller.java [109:144]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException { Message info = (Message) o; info.beforeMarshall(wireFormat); int rc = super.tightMarshal1(wireFormat, o, bs); rc += tightMarshalCachedObject1(wireFormat, info.getProducerId(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getDestination(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getTransactionId(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getOriginalDestination(), bs); rc += tightMarshalNestedObject1(wireFormat, info.getMessageId(), bs); rc += tightMarshalCachedObject1(wireFormat, 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, 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, info.getDataStructure(), bs); rc += tightMarshalCachedObject1(wireFormat, 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()); bs.writeBoolean(info.isDroppable()); rc += tightMarshalObjectArray1(wireFormat, info.getCluster(), bs); rc += tightMarshalLong1(wireFormat, info.getBrokerInTime(), bs); rc += tightMarshalLong1(wireFormat, info.getBrokerOutTime(), bs); return rc + 9; } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v3/MessageMarshaller.java [109:144]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public int tightMarshal1(OpenWireFormat wireFormat, Object o, BooleanStream bs) throws IOException { Message info = (Message) o; info.beforeMarshall(wireFormat); int rc = super.tightMarshal1(wireFormat, o, bs); rc += tightMarshalCachedObject1(wireFormat, info.getProducerId(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getDestination(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getTransactionId(), bs); rc += tightMarshalCachedObject1(wireFormat, info.getOriginalDestination(), bs); rc += tightMarshalNestedObject1(wireFormat, info.getMessageId(), bs); rc += tightMarshalCachedObject1(wireFormat, 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, 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, info.getDataStructure(), bs); rc += tightMarshalCachedObject1(wireFormat, 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()); bs.writeBoolean(info.isDroppable()); rc += tightMarshalObjectArray1(wireFormat, info.getCluster(), bs); rc += tightMarshalLong1(wireFormat, info.getBrokerInTime(), bs); rc += tightMarshalLong1(wireFormat, info.getBrokerOutTime(), bs); return rc + 9; } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -