This is an automated email from the ASF dual-hosted git repository.
clebertsuconic pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/main by this push:
new 8ad0038fc0 ARTEMIS-5099 fix impossible cast in AMQPLargeMessage
8ad0038fc0 is described below
commit 8ad0038fc0a045f4b275939f253aa8154683afde
Author: Justin Bertram <[email protected]>
AuthorDate: Wed Jan 15 12:04:01 2025 -0600
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 | 12 ------------
1 file changed, 12 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 7aca908ad0..24c3b4c129 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
@@ -27,7 +27,6 @@ import org.apache.activemq.artemis.api.core.ActiveMQBuffer;
import org.apache.activemq.artemis.api.core.ActiveMQException;
import org.apache.activemq.artemis.api.core.ICoreMessage;
import org.apache.activemq.artemis.api.core.Message;
-import org.apache.activemq.artemis.api.core.SimpleString;
import org.apache.activemq.artemis.core.buffers.impl.ChannelBufferWrapper;
import org.apache.activemq.artemis.core.io.SequentialFile;
import org.apache.activemq.artemis.core.message.LargeBodyReader;
@@ -35,7 +34,6 @@ import
org.apache.activemq.artemis.core.persistence.CoreMessageObjectPools;
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;
@@ -659,16 +657,6 @@ public class AMQPLargeMessage extends AMQPMessage
implements LargeServerMessage
@Override
protected void encodeMessage() {
-
}
- @Override
- public void referenceOriginalMessage(final Message original, final
SimpleString originalQueue) {
-
- super.referenceOriginalMessage(original, originalQueue);
-
- if (original instanceof LargeServerMessageImpl) {
- this.largeBody.referenceOriginalMessage(((AMQPLargeMessage)
original).largeBody);
- }
- }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
