From 2e7c7fc7999e3489c1f345880c1bf31dd23299a2 Mon Sep 17 00:00:00 2001 From: Justin Bertram Date: Wed, 15 Jan 2025 12:04:01 -0600 Subject: [PATCH] ARTEMIS-5099 fix impossible cast in AMQPLargeMessage I believe this was likely a copy-and-paste error involving o.a.a.a.c.p.i.j.LargeServerMessageImpl#referenceOriginalMessage. --- .../artemis/protocol/amqp/broker/AMQPLargeMessage.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPLargeMessage.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPLargeMessage.java index 71f708873b4..49186c76938 100644 --- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPLargeMessage.java +++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/AMQPLargeMessage.java @@ -35,7 +35,6 @@ import org.apache.activemq.artemis.core.persistence.Persister; import org.apache.activemq.artemis.core.persistence.StorageManager; import org.apache.activemq.artemis.core.persistence.impl.journal.LargeBody; -import org.apache.activemq.artemis.core.persistence.impl.journal.LargeServerMessageImpl; import org.apache.activemq.artemis.core.server.ActiveMQServerLogger; import org.apache.activemq.artemis.core.server.LargeServerMessage; import org.apache.activemq.artemis.core.server.MessageReference; @@ -660,7 +659,7 @@ public void referenceOriginalMessage(final Message original, final SimpleString super.referenceOriginalMessage(original, originalQueue); - if (original instanceof LargeServerMessageImpl) { + if (original instanceof AMQPLargeMessage) { this.largeBody.referenceOriginalMessage(((AMQPLargeMessage) original).largeBody); } }