ing-mattioni commented on PR #11242:
URL: https://github.com/apache/nifi/pull/11242#issuecomment-4475879325
Thank you @pvillard31 and @exceptionfactory , I made the following changes:
- Added configurable Max Outbound Message Body Size in
nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/PublishAMQP.java:100,
default/bounded at 64 MB.
- Oversized FlowFiles now route to failure before content is read into
memory.
- Removed penalization when routing publish failures to failure.
- Centralized AMQP header insertion with consistent empty-key skip/warn
behavior.
- Added tests for oversized FlowFiles, non-penalized failures, and empty
header keys in
nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/test/java/org/apache/nifi/amqp/processors/PublishAMQPTest.java:177.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
