Class DlqContentTransformFailureListener

java.lang.Object
org.alfresco.elasticsearch.batchindexing.listeners.DlqContentTransformFailureListener
All Implemented Interfaces:
ContentTransformFailureListener

public class DlqContentTransformFailureListener extends Object implements ContentTransformFailureListener
Bridges non-retryable content-transform failures (currently ACS 4xx) into DlqWriter. Registered as a Spring bean; ContentTransformDirectWriter picks it up via ObjectProvider and stays a no-op if no bean is present (e.g. when the DLQ config is disabled).

Stage is always DeadLetterDocument.FailureStage.CONTENT_WRITER — the content writer is the only caller. Separate from the metadata / path bridges so operators can tell content-side failures apart in the DLQ index without parsing the failureType.

  • Constructor Details

    • DlqContentTransformFailureListener

      public DlqContentTransformFailureListener(DlqWriter dlqWriter)
  • Method Details

    • onContentTransformFailure

      public void onContentTransformFailure(Long dbId, String nodeRef, Long sourceCommitTimeMs, String failureType, String failureReason)
      Specified by:
      onContentTransformFailure in interface ContentTransformFailureListener
      Parameters:
      dbId - source node database id (never null — the writer only calls this after a per-node lookup)
      nodeRef - Alfresco node reference (never null)
      sourceCommitTimeMs - best-effort event/commit time in epoch ms; may be null
      failureType - short classifier (e.g. TRANSFORM_HTTP_400); never null
      failureReason - human-readable reason from the transform layer; may be null