[jira] [Commented] (JAMES-4035) ActiveMQ not deleting files
[ https://issues.apache.org/jira/browse/JAMES-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847347#comment-17847347 ] Benoit Tellier commented on JAMES-4035: --- 4/ Which operating system are you using? > ActiveMQ not deleting files > --- > > Key: JAMES-4035 > URL: https://issues.apache.org/jira/browse/JAMES-4035 > Project: James Server > Issue Type: Bug > Components: Blob >Affects Versions: 3.7.1 >Reporter: Yoram Halberstam >Priority: Critical > > Hi, > These are emails for an account I deleted on James 3.7.1 but it the blob have > not been deleted. Do you know how to force deletion? > {code:java} > james-server-spring-app-3.7.1/var# du -h > 1.6G ./store/activemq/brokers/KahaDB > 1.6G ./store/activemq/brokers > 301M ./store/activemq/blob-transfer/6 > 303M ./store/activemq/blob-transfer/9 > 302M ./store/activemq/blob-transfer/8 > 305M ./store/activemq/blob-transfer/3 > 303M ./store/activemq/blob-transfer/10 > 303M ./store/activemq/blob-transfer/5 > 303M ./store/activemq/blob-transfer/7 > 304M ./store/activemq/blob-transfer/4 > 303M ./store/activemq/blob-transfer/2 > 305M ./store/activemq/blob-transfer/1 > 3.0G ./store/activemq/blob-transfer > {code} > Regards > Yoram > -- This message was sent by Atlassian Jira (v8.20.10#820010) - To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org
[jira] [Commented] (JAMES-4035) ActiveMQ not deleting files
[ https://issues.apache.org/jira/browse/JAMES-4035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847346#comment-17847346 ] Benoit Tellier commented on JAMES-4035: --- Hello, This looks weird to me... Can I ask you few questions? 1/ Have you tried later releases in the 3.7.x branch? It looks like https://github.com/apache/james-project/blob/master/CHANGELOG.md#374---2023-03-20 ? 2/ I do not exactly understand the meaning of "delete an account". Can you provide details? 3/ Any error in the logs? Thanks. > ActiveMQ not deleting files > --- > > Key: JAMES-4035 > URL: https://issues.apache.org/jira/browse/JAMES-4035 > Project: James Server > Issue Type: Bug > Components: Blob >Affects Versions: 3.7.1 >Reporter: Yoram Halberstam >Priority: Critical > > Hi, > These are emails for an account I deleted on James 3.7.1 but it the blob have > not been deleted. Do you know how to force deletion? > {code:java} > james-server-spring-app-3.7.1/var# du -h > 1.6G ./store/activemq/brokers/KahaDB > 1.6G ./store/activemq/brokers > 301M ./store/activemq/blob-transfer/6 > 303M ./store/activemq/blob-transfer/9 > 302M ./store/activemq/blob-transfer/8 > 305M ./store/activemq/blob-transfer/3 > 303M ./store/activemq/blob-transfer/10 > 303M ./store/activemq/blob-transfer/5 > 303M ./store/activemq/blob-transfer/7 > 304M ./store/activemq/blob-transfer/4 > 303M ./store/activemq/blob-transfer/2 > 305M ./store/activemq/blob-transfer/1 > 3.0G ./store/activemq/blob-transfer > {code} > Regards > Yoram > -- This message was sent by Atlassian Jira (v8.20.10#820010) - To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org
[jira] [Created] (JAMES-4035) ActiveMQ not deleting files
Yoram Halberstam created JAMES-4035: --- Summary: ActiveMQ not deleting files Key: JAMES-4035 URL: https://issues.apache.org/jira/browse/JAMES-4035 Project: James Server Issue Type: Bug Components: Blob Affects Versions: 3.7.1 Reporter: Yoram Halberstam Hi, These are emails for an account I deleted on James 3.7.1 but it the blob have not been deleted. Do you know how to force deletion? {code:java} james-server-spring-app-3.7.1/var# du -h 1.6G ./store/activemq/brokers/KahaDB 1.6G ./store/activemq/brokers 301M ./store/activemq/blob-transfer/6 303M ./store/activemq/blob-transfer/9 302M ./store/activemq/blob-transfer/8 305M ./store/activemq/blob-transfer/3 303M ./store/activemq/blob-transfer/10 303M ./store/activemq/blob-transfer/5 303M ./store/activemq/blob-transfer/7 304M ./store/activemq/blob-transfer/4 303M ./store/activemq/blob-transfer/2 305M ./store/activemq/blob-transfer/1 3.0G ./store/activemq/blob-transfer {code} Regards Yoram -- This message was sent by Atlassian Jira (v8.20.10#820010) - To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org
(james-jspf) branch master updated: [FIX] AsynchronousSPFExecutor should chain correctly DNSLookupContinuation
This is an automated email from the ASF dual-hosted git repository. btellier pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-jspf.git The following commit(s) were added to refs/heads/master by this push: new e188ef5 [FIX] AsynchronousSPFExecutor should chain correctly DNSLookupContinuation e188ef5 is described below commit e188ef5db6a76dc687faa0d464eabc06c4896339 Author: Benoit TELLIER AuthorDate: Fri May 17 11:08:15 2024 +0200 [FIX] AsynchronousSPFExecutor should chain correctly DNSLookupContinuation --- .../jspf/executor/AsynchronousSPFExecutor.java | 72 -- .../AsynchronousSPFExecutorIntegrationTest.java| 42 + 2 files changed, 82 insertions(+), 32 deletions(-) diff --git a/resolver/src/main/java/org/apache/james/jspf/executor/AsynchronousSPFExecutor.java b/resolver/src/main/java/org/apache/james/jspf/executor/AsynchronousSPFExecutor.java index 2ec4e9d..0b950b3 100644 --- a/resolver/src/main/java/org/apache/james/jspf/executor/AsynchronousSPFExecutor.java +++ b/resolver/src/main/java/org/apache/james/jspf/executor/AsynchronousSPFExecutor.java @@ -50,39 +50,47 @@ public class AsynchronousSPFExecutor implements SPFExecutor { * @see SPFExecutor#execute(SPFSession, FutureSPFResult) */ public void execute(SPFSession session, FutureSPFResult result) { -SPFChecker checker; -while ((checker = session.popChecker()) != null) { -// only execute checkers we added (better recursivity) -LOGGER.debug("Executing checker: {}", checker); -SPFChecker finalChecker = checker; -try { -DNSLookupContinuation cont = checker.checkSPF(session); -if (cont == null) { -continue; -} -// if the checker returns a continuation we return it -dnsProbe.getRecordsAsync(cont.getRequest()) -.thenAccept(results -> { -try { -cont.getListener().onDNSResponse(new DNSResponse(results), session); -} catch (PermErrorException | NoneException | TempErrorException | NeutralException e) { -handleError(session, finalChecker, e); -} -}) -.exceptionally(e -> { -if (e instanceof TimeoutException) { -handleTimeout(session, finalChecker, cont, (TimeoutException) e); -} -if (e.getCause() instanceof TimeoutException) { -handleTimeout(session, finalChecker, cont, (TimeoutException) e.getCause()); -} -return null; -}); -} catch (Exception e) { -handleError(session, checker, e); -} +SPFChecker checker = session.popChecker(); +if (checker == null) { +result.setSPFResult(session); +return; +} +// only execute checkers we added (better recursivity) +LOGGER.debug("Executing checker: {}", checker); +try { +DNSLookupContinuation cont = checker.checkSPF(session); +handleCont(session, result, cont, checker); +} catch (Exception e) { +handleError(session, checker, e); +result.setSPFResult(session); +} +} + +private void handleCont(SPFSession session, FutureSPFResult result, DNSLookupContinuation cont, SPFChecker checker) { +if (cont != null) { +// if the checker returns a continuation we return it +dnsProbe.getRecordsAsync(cont.getRequest()) +.thenAccept(results -> { +try { +DNSLookupContinuation dnsLookupContinuation = cont.getListener().onDNSResponse(new DNSResponse(results), session); +handleCont(session, result, dnsLookupContinuation, checker); +} catch (PermErrorException | NoneException | TempErrorException | NeutralException e) { +handleError(session, checker, e); +} +}) +.exceptionally(e -> { +if (e instanceof TimeoutException) { +handleTimeout(session, checker, cont, (TimeoutException) e); +} +if (e.getCause() instanceof TimeoutException) { +handleTimeout(session, checker, cont, (TimeoutException) e.getCause()); +} +result.setSPFResult(session); +return null; +}); +} else { +execute(session, result); } -result.setSPFResult(session); } private void handleTimeout(SPFSession
[BUILD-STABLE]: Job 'james/ApacheJames/master [master] [1368]'
BUILD-STABLE: Job 'james/ApacheJames/master [master] [1368]': Is back to normal. - To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org For additional commands, e-mail: server-dev-h...@james.apache.org