com.trekglobal.idempiere.rest.api.testcom.trekglobal.idempiere.rest.api.test-1.0.0-SNAPSHOT.pompom.xmlcom.trekglobal.idempiere.extensions6b92f8ef39daeb8f6844c4e5ed1a4ce2pom1.0.0-SNAPSHOThttps://jenkins.younex.de/job/idempiere-rest-master/com.trekglobal.idempiere.extensions$com.trekglobal.idempiere.rest.api.test/131/mavenArtifacts/com.trekglobal.idempiere.rest.api.test-1.0.0-SNAPSHOT.pomcom.trekglobal.idempiere.rest.api.test-1.0.0-SNAPSHOT.pomcom.trekglobal.idempiere.extensions/com.trekglobal.idempiere.rest.api.test/1.0.0-SNAPSHOT/com.trekglobal.idempiere.rest.api.test-1.0.0-SNAPSHOT.pomfalsecom.trekglobal.idempiere.rest.api.test0-1idempiere-rest-master » com.trekglobal.idempiere.rest.api.test com.trekglobal.idempiere.rest.api.test131falsefalse131-1NOT_BUILT1790822647399https://jenkins.younex.de/job/idempiere-rest-master/com.trekglobal.idempiere.extensions$com.trekglobal.idempiere.rest.api.test/131/com.trekglobal.idempiere.rest.api.test/src/com/trekglobal/idempiere/rest/api/webhook/test/WebhookRetryPendingTest.javacom.trekglobal.idempiere.rest.api/src/com/trekglobal/idempiere/rest/api/process/WebhookRetryProcessor.javacom.trekglobal.idempiere.rest.api/src/com/trekglobal/idempiere/rest/api/model/MRestWebhookOutLog.java19880d6384f91804143872262e0670d9272121d01790768942000https://jenkins.younex.de/user/noreplynoreplynoreply@github.comfix(webhook): bound WebhookRetryProcessor memory with batches, skip paused endpoints (#538) * fix(webhook): bound WebhookRetryProcessor memory with batches, skip paused endpoints Fixes bxservice/idempiere-rest#537 Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * test(webhook): cover getPendingRetries batching and paused-endpoint exclusion Refs bxservice/idempiere-rest#537 Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * fix(webhook): enforce retry runtime limit per delivery, not per batch Refs bxservice/idempiere-rest#537 Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * refactor(webhook): use Query.iterate() for pending retries instead of keyset batches Refs bxservice/idempiere-rest#537 Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * perf(webhook): stream pending retries to avoid N+1 row loads Query.iterate() loads IDs up front and re-fetches each row with a separate SELECT, which means one query per delivery on a backlog of millions. Switch to Query.stream() so each delivery is built straight off the open result set, and re-run the query per batch of COMMIT_INTERVAL so commits never happen while the cursor is open. Processed rows leave the WHERE clause, so each fresh batch continues where the previous one stopped. Refs #537 Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> * fix(webhook): cap pending-retry query with SQL LIMIT per batch Query.stream() sets no fetch size, so pgJDBC buffers the whole result set before the first row is read; stopping after COMMIT_INTERVAL rows in Java still loaded the entire backlog. Pass the batch size into streamPendingRetries and apply it via setPageSize, so each query returns at most one batch. No OFFSET is needed since processed rows leave the WHERE clause. Also check the runtime deadline before opening each batch query. Refs #537 Co-Authored-By: Claude Opus 5.5 (1M context) <noreply@anthropic.com> --------- Co-authored-by: Claude Opus 5.5 (1M context) <noreply@anthropic.com> 2026-09-30 13:49:02 +020019880d6384f91804143872262e0670d9272121d0fix(webhook): bound WebhookRetryProcessor memory with batches, skip paused endpoints (#538)addcom.trekglobal.idempiere.rest.api.test/src/com/trekglobal/idempiere/rest/api/webhook/test/WebhookRetryPendingTest.javaeditcom.trekglobal.idempiere.rest.api/src/com/trekglobal/idempiere/rest/api/process/WebhookRetryProcessor.javaeditcom.trekglobal.idempiere.rest.api/src/com/trekglobal/idempiere/rest/api/model/MRestWebhookOutLog.javahttps://jenkins.younex.de/user/noreplynoreplyhttps://jenkins.younex.de/job/idempiere-rest-master/com.trekglobal.idempiere.extensions$com.trekglobal.idempiere.rest.api.test/131/mavenArtifacts/com.trekglobal.idempiere.rest.api.testcom.trekglobal.idempiere.rest.api.test-1.0.0-SNAPSHOT.pompom.xmlcom.trekglobal.idempiere.extensions6b92f8ef39daeb8f6844c4e5ed1a4ce2pom1.0.0-SNAPSHOThttps://jenkins.younex.de/job/idempiere-rest-master/com.trekglobal.idempiere.extensions$com.trekglobal.idempiere.rest.api.test/131/mavenArtifacts/