Github user clebertsuconic commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/1853#discussion_r166636796
--- 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 --
JournalCompatibilityTest under compatibility-tests.
I don't think the test is using paging. we should just extend the test to
use paging.
I can help you with that if you have questions.
---
