openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v6/MessageMarshaller.java [268:303]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { Message info = (Message) o; info.beforeMarshall(wireFormat); super.looseMarshal(wireFormat, o, dataOut); looseMarshalCachedObject(wireFormat, info.getProducerId(), dataOut); looseMarshalCachedObject(wireFormat, info.getDestination(), dataOut); looseMarshalCachedObject(wireFormat, info.getTransactionId(), dataOut); looseMarshalCachedObject(wireFormat, info.getOriginalDestination(), dataOut); looseMarshalNestedObject(wireFormat, info.getMessageId(), dataOut); looseMarshalCachedObject(wireFormat, info.getOriginalTransactionId(), dataOut); looseMarshalString(info.getGroupId(), dataOut); dataOut.writeInt(info.getGroupSequence()); looseMarshalString(info.getCorrelationId(), dataOut); dataOut.writeBoolean(info.isPersistent()); looseMarshalLong(wireFormat, info.getExpiration(), dataOut); dataOut.writeByte(info.getPriority()); looseMarshalNestedObject(wireFormat, info.getReplyTo(), dataOut); looseMarshalLong(wireFormat, info.getTimestamp(), dataOut); looseMarshalString(info.getType(), dataOut); looseMarshalByteSequence(wireFormat, info.getContent(), dataOut); looseMarshalByteSequence(wireFormat, info.getMarshalledProperties(), dataOut); looseMarshalNestedObject(wireFormat, info.getDataStructure(), dataOut); looseMarshalCachedObject(wireFormat, info.getTargetConsumerId(), dataOut); dataOut.writeBoolean(info.isCompressed()); dataOut.writeInt(info.getRedeliveryCounter()); looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut); looseMarshalLong(wireFormat, info.getArrival(), dataOut); looseMarshalString(info.getUserId(), dataOut); dataOut.writeBoolean(info.isRecievedByDFBridge()); dataOut.writeBoolean(info.isDroppable()); looseMarshalObjectArray(wireFormat, info.getCluster(), dataOut); looseMarshalLong(wireFormat, info.getBrokerInTime(), dataOut); looseMarshalLong(wireFormat, info.getBrokerOutTime(), dataOut); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v8/MessageMarshaller.java [268:303]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { Message info = (Message) o; info.beforeMarshall(wireFormat); super.looseMarshal(wireFormat, o, dataOut); looseMarshalCachedObject(wireFormat, info.getProducerId(), dataOut); looseMarshalCachedObject(wireFormat, info.getDestination(), dataOut); looseMarshalCachedObject(wireFormat, info.getTransactionId(), dataOut); looseMarshalCachedObject(wireFormat, info.getOriginalDestination(), dataOut); looseMarshalNestedObject(wireFormat, info.getMessageId(), dataOut); looseMarshalCachedObject(wireFormat, info.getOriginalTransactionId(), dataOut); looseMarshalString(info.getGroupId(), dataOut); dataOut.writeInt(info.getGroupSequence()); looseMarshalString(info.getCorrelationId(), dataOut); dataOut.writeBoolean(info.isPersistent()); looseMarshalLong(wireFormat, info.getExpiration(), dataOut); dataOut.writeByte(info.getPriority()); looseMarshalNestedObject(wireFormat, info.getReplyTo(), dataOut); looseMarshalLong(wireFormat, info.getTimestamp(), dataOut); looseMarshalString(info.getType(), dataOut); looseMarshalByteSequence(wireFormat, info.getContent(), dataOut); looseMarshalByteSequence(wireFormat, info.getMarshalledProperties(), dataOut); looseMarshalNestedObject(wireFormat, info.getDataStructure(), dataOut); looseMarshalCachedObject(wireFormat, info.getTargetConsumerId(), dataOut); dataOut.writeBoolean(info.isCompressed()); dataOut.writeInt(info.getRedeliveryCounter()); looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut); looseMarshalLong(wireFormat, info.getArrival(), dataOut); looseMarshalString(info.getUserId(), dataOut); dataOut.writeBoolean(info.isRecievedByDFBridge()); dataOut.writeBoolean(info.isDroppable()); looseMarshalObjectArray(wireFormat, info.getCluster(), dataOut); looseMarshalLong(wireFormat, info.getBrokerInTime(), dataOut); looseMarshalLong(wireFormat, info.getBrokerOutTime(), dataOut); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v9/MessageMarshaller.java [268:303]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { Message info = (Message) o; info.beforeMarshall(wireFormat); super.looseMarshal(wireFormat, o, dataOut); looseMarshalCachedObject(wireFormat, info.getProducerId(), dataOut); looseMarshalCachedObject(wireFormat, info.getDestination(), dataOut); looseMarshalCachedObject(wireFormat, info.getTransactionId(), dataOut); looseMarshalCachedObject(wireFormat, info.getOriginalDestination(), dataOut); looseMarshalNestedObject(wireFormat, info.getMessageId(), dataOut); looseMarshalCachedObject(wireFormat, info.getOriginalTransactionId(), dataOut); looseMarshalString(info.getGroupId(), dataOut); dataOut.writeInt(info.getGroupSequence()); looseMarshalString(info.getCorrelationId(), dataOut); dataOut.writeBoolean(info.isPersistent()); looseMarshalLong(wireFormat, info.getExpiration(), dataOut); dataOut.writeByte(info.getPriority()); looseMarshalNestedObject(wireFormat, info.getReplyTo(), dataOut); looseMarshalLong(wireFormat, info.getTimestamp(), dataOut); looseMarshalString(info.getType(), dataOut); looseMarshalByteSequence(wireFormat, info.getContent(), dataOut); looseMarshalByteSequence(wireFormat, info.getMarshalledProperties(), dataOut); looseMarshalNestedObject(wireFormat, info.getDataStructure(), dataOut); looseMarshalCachedObject(wireFormat, info.getTargetConsumerId(), dataOut); dataOut.writeBoolean(info.isCompressed()); dataOut.writeInt(info.getRedeliveryCounter()); looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut); looseMarshalLong(wireFormat, info.getArrival(), dataOut); looseMarshalString(info.getUserId(), dataOut); dataOut.writeBoolean(info.isRecievedByDFBridge()); dataOut.writeBoolean(info.isDroppable()); looseMarshalObjectArray(wireFormat, info.getCluster(), dataOut); looseMarshalLong(wireFormat, info.getBrokerInTime(), dataOut); looseMarshalLong(wireFormat, info.getBrokerOutTime(), dataOut); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v7/MessageMarshaller.java [268:303]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { Message info = (Message) o; info.beforeMarshall(wireFormat); super.looseMarshal(wireFormat, o, dataOut); looseMarshalCachedObject(wireFormat, info.getProducerId(), dataOut); looseMarshalCachedObject(wireFormat, info.getDestination(), dataOut); looseMarshalCachedObject(wireFormat, info.getTransactionId(), dataOut); looseMarshalCachedObject(wireFormat, info.getOriginalDestination(), dataOut); looseMarshalNestedObject(wireFormat, info.getMessageId(), dataOut); looseMarshalCachedObject(wireFormat, info.getOriginalTransactionId(), dataOut); looseMarshalString(info.getGroupId(), dataOut); dataOut.writeInt(info.getGroupSequence()); looseMarshalString(info.getCorrelationId(), dataOut); dataOut.writeBoolean(info.isPersistent()); looseMarshalLong(wireFormat, info.getExpiration(), dataOut); dataOut.writeByte(info.getPriority()); looseMarshalNestedObject(wireFormat, info.getReplyTo(), dataOut); looseMarshalLong(wireFormat, info.getTimestamp(), dataOut); looseMarshalString(info.getType(), dataOut); looseMarshalByteSequence(wireFormat, info.getContent(), dataOut); looseMarshalByteSequence(wireFormat, info.getMarshalledProperties(), dataOut); looseMarshalNestedObject(wireFormat, info.getDataStructure(), dataOut); looseMarshalCachedObject(wireFormat, info.getTargetConsumerId(), dataOut); dataOut.writeBoolean(info.isCompressed()); dataOut.writeInt(info.getRedeliveryCounter()); looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut); looseMarshalLong(wireFormat, info.getArrival(), dataOut); looseMarshalString(info.getUserId(), dataOut); dataOut.writeBoolean(info.isRecievedByDFBridge()); dataOut.writeBoolean(info.isDroppable()); looseMarshalObjectArray(wireFormat, info.getCluster(), dataOut); looseMarshalLong(wireFormat, info.getBrokerInTime(), dataOut); looseMarshalLong(wireFormat, info.getBrokerOutTime(), dataOut); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v5/MessageMarshaller.java [268:303]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { Message info = (Message) o; info.beforeMarshall(wireFormat); super.looseMarshal(wireFormat, o, dataOut); looseMarshalCachedObject(wireFormat, info.getProducerId(), dataOut); looseMarshalCachedObject(wireFormat, info.getDestination(), dataOut); looseMarshalCachedObject(wireFormat, info.getTransactionId(), dataOut); looseMarshalCachedObject(wireFormat, info.getOriginalDestination(), dataOut); looseMarshalNestedObject(wireFormat, info.getMessageId(), dataOut); looseMarshalCachedObject(wireFormat, info.getOriginalTransactionId(), dataOut); looseMarshalString(info.getGroupId(), dataOut); dataOut.writeInt(info.getGroupSequence()); looseMarshalString(info.getCorrelationId(), dataOut); dataOut.writeBoolean(info.isPersistent()); looseMarshalLong(wireFormat, info.getExpiration(), dataOut); dataOut.writeByte(info.getPriority()); looseMarshalNestedObject(wireFormat, info.getReplyTo(), dataOut); looseMarshalLong(wireFormat, info.getTimestamp(), dataOut); looseMarshalString(info.getType(), dataOut); looseMarshalByteSequence(wireFormat, info.getContent(), dataOut); looseMarshalByteSequence(wireFormat, info.getMarshalledProperties(), dataOut); looseMarshalNestedObject(wireFormat, info.getDataStructure(), dataOut); looseMarshalCachedObject(wireFormat, info.getTargetConsumerId(), dataOut); dataOut.writeBoolean(info.isCompressed()); dataOut.writeInt(info.getRedeliveryCounter()); looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut); looseMarshalLong(wireFormat, info.getArrival(), dataOut); looseMarshalString(info.getUserId(), dataOut); dataOut.writeBoolean(info.isRecievedByDFBridge()); dataOut.writeBoolean(info.isDroppable()); looseMarshalObjectArray(wireFormat, info.getCluster(), dataOut); looseMarshalLong(wireFormat, info.getBrokerInTime(), dataOut); looseMarshalLong(wireFormat, info.getBrokerOutTime(), dataOut); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v4/MessageMarshaller.java [268:303]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { Message info = (Message) o; info.beforeMarshall(wireFormat); super.looseMarshal(wireFormat, o, dataOut); looseMarshalCachedObject(wireFormat, info.getProducerId(), dataOut); looseMarshalCachedObject(wireFormat, info.getDestination(), dataOut); looseMarshalCachedObject(wireFormat, info.getTransactionId(), dataOut); looseMarshalCachedObject(wireFormat, info.getOriginalDestination(), dataOut); looseMarshalNestedObject(wireFormat, info.getMessageId(), dataOut); looseMarshalCachedObject(wireFormat, info.getOriginalTransactionId(), dataOut); looseMarshalString(info.getGroupId(), dataOut); dataOut.writeInt(info.getGroupSequence()); looseMarshalString(info.getCorrelationId(), dataOut); dataOut.writeBoolean(info.isPersistent()); looseMarshalLong(wireFormat, info.getExpiration(), dataOut); dataOut.writeByte(info.getPriority()); looseMarshalNestedObject(wireFormat, info.getReplyTo(), dataOut); looseMarshalLong(wireFormat, info.getTimestamp(), dataOut); looseMarshalString(info.getType(), dataOut); looseMarshalByteSequence(wireFormat, info.getContent(), dataOut); looseMarshalByteSequence(wireFormat, info.getMarshalledProperties(), dataOut); looseMarshalNestedObject(wireFormat, info.getDataStructure(), dataOut); looseMarshalCachedObject(wireFormat, info.getTargetConsumerId(), dataOut); dataOut.writeBoolean(info.isCompressed()); dataOut.writeInt(info.getRedeliveryCounter()); looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut); looseMarshalLong(wireFormat, info.getArrival(), dataOut); looseMarshalString(info.getUserId(), dataOut); dataOut.writeBoolean(info.isRecievedByDFBridge()); dataOut.writeBoolean(info.isDroppable()); looseMarshalObjectArray(wireFormat, info.getCluster(), dataOut); looseMarshalLong(wireFormat, info.getBrokerInTime(), dataOut); looseMarshalLong(wireFormat, info.getBrokerOutTime(), dataOut); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - openwire-legacy/src/main/java/org/apache/activemq/openwire/codec/v3/MessageMarshaller.java [268:303]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { Message info = (Message) o; info.beforeMarshall(wireFormat); super.looseMarshal(wireFormat, o, dataOut); looseMarshalCachedObject(wireFormat, info.getProducerId(), dataOut); looseMarshalCachedObject(wireFormat, info.getDestination(), dataOut); looseMarshalCachedObject(wireFormat, info.getTransactionId(), dataOut); looseMarshalCachedObject(wireFormat, info.getOriginalDestination(), dataOut); looseMarshalNestedObject(wireFormat, info.getMessageId(), dataOut); looseMarshalCachedObject(wireFormat, info.getOriginalTransactionId(), dataOut); looseMarshalString(info.getGroupId(), dataOut); dataOut.writeInt(info.getGroupSequence()); looseMarshalString(info.getCorrelationId(), dataOut); dataOut.writeBoolean(info.isPersistent()); looseMarshalLong(wireFormat, info.getExpiration(), dataOut); dataOut.writeByte(info.getPriority()); looseMarshalNestedObject(wireFormat, info.getReplyTo(), dataOut); looseMarshalLong(wireFormat, info.getTimestamp(), dataOut); looseMarshalString(info.getType(), dataOut); looseMarshalByteSequence(wireFormat, info.getContent(), dataOut); looseMarshalByteSequence(wireFormat, info.getMarshalledProperties(), dataOut); looseMarshalNestedObject(wireFormat, info.getDataStructure(), dataOut); looseMarshalCachedObject(wireFormat, info.getTargetConsumerId(), dataOut); dataOut.writeBoolean(info.isCompressed()); dataOut.writeInt(info.getRedeliveryCounter()); looseMarshalObjectArray(wireFormat, info.getBrokerPath(), dataOut); looseMarshalLong(wireFormat, info.getArrival(), dataOut); looseMarshalString(info.getUserId(), dataOut); dataOut.writeBoolean(info.isRecievedByDFBridge()); dataOut.writeBoolean(info.isDroppable()); looseMarshalObjectArray(wireFormat, info.getCluster(), dataOut); looseMarshalLong(wireFormat, info.getBrokerInTime(), dataOut); looseMarshalLong(wireFormat, info.getBrokerOutTime(), dataOut); } - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -