diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java
index 9b8177ebc2..aac727dae5 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/AbstractJournalStorageManager.java
@@ -1030,7 +1030,7 @@ public abstract class AbstractJournalStorageManager extends CriticalComponentImp
                         if (pageTX == null) {
                            ActiveMQServerLogger.LOGGER.journalCannotFindPageTX(pageUpdate.pageTX);
                         } else {
-                           if (!pageTX.onUpdate(pageUpdate.recods, null, null)) {
+                           if (!pageTX.onUpdate(pageUpdate.records, null, null)) {
                               invalidPGTx = pageTX;
                            }
                         }
diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PageUpdateTXEncoding.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PageUpdateTXEncoding.java
index 6db8270f30..83a3676f2f 100644
--- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PageUpdateTXEncoding.java
+++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PageUpdateTXEncoding.java
@@ -27,11 +27,11 @@ public class PageUpdateTXEncoding implements EncodingSupport {
 
    public long pageTX;
 
-   public int recods;
+   public int records;
 
    @Override
    public String toString() {
-      return "PageUpdateTXEncoding [pageTX=" + pageTX + ", recods=" + recods + "]";
+      return "PageUpdateTXEncoding [pageTX=" + pageTX + ", records=" + records + "]";
    }
 
    public PageUpdateTXEncoding() {
@@ -39,19 +39,19 @@ public class PageUpdateTXEncoding implements EncodingSupport {
 
    public PageUpdateTXEncoding(final long pageTX, final int records) {
       this.pageTX = pageTX;
-      this.recods = records;
+      this.records = records;
    }
 
    @Override
    public void decode(ActiveMQBuffer buffer) {
       this.pageTX = buffer.readLong();
-      this.recods = buffer.readInt();
+      this.records = buffer.readInt();
    }
 
    @Override
    public void encode(ActiveMQBuffer buffer) {
       buffer.writeLong(pageTX);
-      buffer.writeInt(recods);
+      buffer.writeInt(records);
    }
 
    @Override