treshenkov/credit_tracker
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

flag calc

Browse source
This commit is contained in:
etreschenkov 2025-11-11 14:36:46 +03:00
parent aaf91195b1
commit 53a2ab77a9
3 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/main/java/ru/nbch/credit_tracker/service/task/PipelinePackageManager.java
View file

@ -110,7 +110,7 @@ public class PipelinePackageManager {
} }
SignalXmlFilePayload res = (SignalXmlFilePayload) v; SignalXmlFilePayload res = (SignalXmlFilePayload) v;
log.trace("Signal file by path: {} is completed", res.getSignalXmlFilePath()); log.trace("Signal file by path: {} is completed", res.getSignalXmlFilePath());
signalRestService.setupMonitoring(res.getSignalXmlFilePath().toString()); // signalRestService.setupMonitoring(res.getSignalXmlFilePath().toString());
} catch (Exception ex) { } catch (Exception ex) {
log.error("pipeline finished with error{}", ExceptionUtils.getStackTrace(ex)); log.error("pipeline finished with error{}", ExceptionUtils.getStackTrace(ex));
} finally { } finally {

4
src/main/java/ru/nbch/credit_tracker/service/task/Stage.java
View file

@ -66,7 +66,7 @@ public class Stage<X extends StagePayload, Z extends StagePayload> implements Ru
} }
if (b == null) continue; if (b == null) continue;
if (b.isPoison()) { if (b.isPoison()) {
log.debug("Got poison"); log.info("Got poison");
// дождаться всех in-flight задач // дождаться всех in-flight задач
for (Future<Z> f : inflight) { for (Future<Z> f : inflight) {
if (wasInterrupted()) { if (wasInterrupted()) {
@ -129,6 +129,7 @@ public class Stage<X extends StagePayload, Z extends StagePayload> implements Ru
} }
q.put(b); q.put(b);
} catch (InterruptedException e) { } catch (InterruptedException e) {
log.error("Error: {}", ExceptionUtils.getStackTrace(e));
Thread.currentThread().interrupt(); Thread.currentThread().interrupt();
} }
} }
@ -137,6 +138,7 @@ public class Stage<X extends StagePayload, Z extends StagePayload> implements Ru
try { try {
return q.poll(timeout.toMillis(), TimeUnit.MILLISECONDS); return q.poll(timeout.toMillis(), TimeUnit.MILLISECONDS);
} catch (InterruptedException e) { } catch (InterruptedException e) {
log.error("Error: {}", ExceptionUtils.getStackTrace(e));
Thread.currentThread().interrupt(); Thread.currentThread().interrupt();
return null; return null;
} }

1
src/main/java/ru/nbch/credit_tracker/service/task/impl/KickPipeLineImpl.java
View file

@ -62,6 +62,7 @@ public class KickPipeLineImpl implements IPipeLineStarter<SubjectPayload> {
} catch (IOException e) { } catch (IOException e) {
throw new RuntimeException("Error while parsing monitoring request", e); throw new RuntimeException("Error while parsing monitoring request", e);
} finally { } finally {
log.debug("Send poison pill");
firstQueue.add(new SubjectPayload(true)); firstQueue.add(new SubjectPayload(true));
} }
} }