diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/settings/impl/AddressSettings.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/settings/impl/AddressSettings.java index b864c6ff24f..cb5d0b3466f 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/settings/impl/AddressSettings.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/settings/impl/AddressSettings.java @@ -1047,7 +1047,7 @@ public int getEncodeSize() { return BufferHelper.sizeOfNullableSimpleString(addressFullMessagePolicy != null ? addressFullMessagePolicy.toString() : null) + BufferHelper.sizeOfNullableLong(maxSizeBytes) + - BufferHelper.sizeOfNullableLong(Long.valueOf(pageSizeBytes)) + + BufferHelper.sizeOfNullableLong(pageSizeBytes == null ? null : Long.valueOf(pageSizeBytes)) + BufferHelper.sizeOfNullableInteger(pageMaxCache) + BufferHelper.sizeOfNullableBoolean(dropMessagesWhenFull) + BufferHelper.sizeOfNullableInteger(maxDeliveryAttempts) + @@ -1098,7 +1098,7 @@ public void encode(ActiveMQBuffer buffer) { BufferHelper.writeNullableLong(buffer, maxSizeBytes); - BufferHelper.writeNullableLong(buffer, Long.valueOf(pageSizeBytes)); + BufferHelper.writeNullableLong(buffer, pageSizeBytes == null ? null : Long.valueOf(pageSizeBytes)); BufferHelper.writeNullableInteger(buffer, pageMaxCache);