Github user cshannon commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1853#discussion_r166632761
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PageCountPendingImpl.java
---
@@ -62,21 +67,41 @@ public long getPageID() {
return pageID;
}
+ /**
+ * @return the persistentSize
+ */
+ @Override
+ public long getPersistentSize() {
+ return persistentSize;
+ }
+
+ /**
+ * @param persistentSize the persistentSize to set
+ */
+ public void setPersistentSize(long persistentSize) {
+ this.persistentSize = persistentSize;
+ }
+
@Override
public int getEncodeSize() {
- return DataConstants.SIZE_LONG * 2;
+ return DataConstants.SIZE_LONG * 3;
}
@Override
public void encode(ActiveMQBuffer buffer) {
buffer.writeLong(queueID);
buffer.writeLong(pageID);
+ buffer.writeLong(persistentSize);
--- End diff --
I can add a compatibility test. The value will just be a default
(@michaelandrepearce wants me to use -1 instead of 0 and i guess we just would
ignore it if not set for the count).
Where's the journal test located in the test suite?
---
