diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PersistentQueueBindingEncoding.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PersistentQueueBindingEncoding.java index 570a7fcb40..0f974aa175 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PersistentQueueBindingEncoding.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/persistence/impl/journal/codec/PersistentQueueBindingEncoding.java @@ -326,6 +326,11 @@ public class PersistentQueueBindingEncoding implements EncodingSupport, QueueBin } else { lastValue = ActiveMQDefaultConfiguration.getDefaultLastValue(); } + if (buffer.readableBytes() > 0) { + configurationManaged = buffer.readBoolean(); + } else { + configurationManaged = false; + } if (buffer.readableBytes() > 0) { consumersBeforeDispatch = buffer.readInt(); } else { @@ -336,11 +341,6 @@ public class PersistentQueueBindingEncoding implements EncodingSupport, QueueBin } else { delayBeforeDispatch = ActiveMQDefaultConfiguration.getDefaultDelayBeforeDispatch(); } - if (buffer.readableBytes() > 0) { - configurationManaged = buffer.readBoolean(); - } else { - configurationManaged = false; - } if (buffer.readableBytes() > 0) { lastValueKey = buffer.readNullableSimpleString(); } else { @@ -365,9 +365,9 @@ public class PersistentQueueBindingEncoding implements EncodingSupport, QueueBin buffer.writeByte(routingType); buffer.writeBoolean(exclusive); buffer.writeBoolean(lastValue); + buffer.writeBoolean(configurationManaged); buffer.writeInt(consumersBeforeDispatch); buffer.writeLong(delayBeforeDispatch); - buffer.writeBoolean(configurationManaged); buffer.writeNullableSimpleString(lastValueKey); buffer.writeBoolean(nonDestructive); } @@ -382,9 +382,9 @@ public class PersistentQueueBindingEncoding implements EncodingSupport, QueueBin DataConstants.SIZE_BYTE + DataConstants.SIZE_BOOLEAN + DataConstants.SIZE_BOOLEAN + + DataConstants.SIZE_BOOLEAN + DataConstants.SIZE_INT + DataConstants.SIZE_LONG + - DataConstants.SIZE_BOOLEAN + SimpleString.sizeofNullableString(lastValueKey) + DataConstants.SIZE_BOOLEAN; }