Package org.alfresco.elasticsearch.batchindexing.listeners

Class DlqPathBulkItemFailureListener

java.lang.Object

org.alfresco.elasticsearch.batchindexing.listeners.DlqPathBulkItemFailureListener

All Implemented Interfaces:

org.alfresco.reindexing.writers.PathBulkItemFailureListener

public class DlqPathBulkItemFailureListener
extends Object
implements org.alfresco.reindexing.writers.PathBulkItemFailureListener

Bridges per-item bulk failures from the path writer into DlqWriter. Registered as a Spring bean; the reindexing module's ElasticsearchPathWriter picks it up via ObjectProvider and stays a no-op if no bean is present.

Stage is always DeadLetterDocument.FailureStage.PATH_WRITER — the path writer is the only caller. Kept separate from DlqBulkItemFailureListener (which serves the metadata writer with stage METADATA_WRITER) so operators can tell the two write paths apart in the DLQ index.

Constructor Summary

Constructors

Constructor	Description
DlqPathBulkItemFailureListener(DlqWriter dlqWriter)

Method Summary

Modifier and Type	Method	Description
void	onPathBulkItemFailure(Long dbId, String nodeRef, Long sourceCommitTimeMs, String errorType, String errorReason)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

DlqPathBulkItemFailureListener

public DlqPathBulkItemFailureListener(DlqWriter dlqWriter)

Method Details

onPathBulkItemFailure

public void onPathBulkItemFailure(Long dbId,
 String nodeRef,
 Long sourceCommitTimeMs,
 String errorType,
 String errorReason)

Specified by:

onPathBulkItemFailure in interface org.alfresco.reindexing.writers.PathBulkItemFailureListener