You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "clebert suconic (Jira)" <ji...@apache.org> on 2019/08/26 15:48:06 UTC
[jira] [Reopened] (ARTEMIS-2371) AMQP: message with very large
header shuts broker down
[ https://issues.apache.org/jira/browse/ARTEMIS-2371?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
clebert suconic reopened ARTEMIS-2371:
--------------------------------------
> AMQP: message with very large header shuts broker down
> ------------------------------------------------------
>
> Key: ARTEMIS-2371
> URL: https://issues.apache.org/jira/browse/ARTEMIS-2371
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Components: AMQP, Broker
> Affects Versions: 2.9.0
> Reporter: Domenico Bruscino
> Priority: Major
> Fix For: 2.10.0
>
> Time Spent: 2h 40m
> Remaining Estimate: 0h
>
> When there is one really large header sent with the message, the broker does not have room for it and shuts down. Using an AMQP client send a message with an extremely large header (>600000 bytes) and broker default configuration this will trigger the following exception:
> {code:java}
> [Thread-0 (ActiveMQ-IO-server-org.apache.activemq.artemis.core.server.impl.ActiveMQServerImpl$7@6bbe85a8)] 11:01:00,087 WARN [org.apache.activemq.artemis.core.server] AMQ222010: Critical IO Error, shutting down the server. file=AIOSequentialFile:/home/dbruscin/Workspace/activemq-artemis/tests/integration-tests/./target/tmp/junit9074908614954602801/journal0-L5672/activemq-data-1.amq, message=Can't write records (size=2097454) bigger than the bufferSize(501760) on the journal: java.lang.IllegalStateException: Can't write records (size=2097454) bigger than the bufferSize(501760) on the journal
> at org.apache.activemq.artemis.core.io.buffer.TimedBuffer.checkSize(TimedBuffer.java:247) [:]
> at org.apache.activemq.artemis.core.io.AbstractSequentialFile.fits(AbstractSequentialFile.java:180) [:]
> at org.apache.activemq.artemis.core.journal.impl.JournalImpl.switchFileIfNecessary(JournalImpl.java:3065) [:]
> at org.apache.activemq.artemis.core.journal.impl.JournalImpl.appendRecord(JournalImpl.java:2796) [:]
> at org.apache.activemq.artemis.core.journal.impl.JournalImpl.access$100(JournalImpl.java:91) [:]
> at org.apache.activemq.artemis.core.journal.impl.JournalImpl$1.run(JournalImpl.java:852) [:]
> at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:42) [:]
> at org.apache.activemq.artemis.utils.actors.OrderedExecutor.doTask(OrderedExecutor.java:31) [:]
> at org.apache.activemq.artemis.utils.actors.ProcessorBase.executePendingTasks(ProcessorBase.java:66) [:]
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [rt.jar:1.8.0_212]
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [rt.jar:1.8.0_212]
> at org.apache.activemq.artemis.utils.ActiveMQThreadFactory$1.run(ActiveMQThreadFactory.java:118) [:]
> {code}
--
This message was sent by Atlassian Jira
(v8.3.2#803003)