From 2645f3df4666753cf7d6567a244d76a41bf2b8b9 Mon Sep 17 00:00:00 2001 From: Benjamin Graf Date: Sat, 21 Mar 2020 10:03:42 +0100 Subject: [PATCH] NO-JIRA: Fix small typo in variable name and toString representation --- .../impl/journal/AbstractJournalStorageManager.java | 2 +- .../impl/journal/codec/PageUpdateTXEncoding.java | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) 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