Package org.alfresco.elasticsearch.batchindexing.listeners

Class DlqPageReadFailureListener

java.lang.Object

org.alfresco.elasticsearch.batchindexing.listeners.DlqPageReadFailureListener

All Implemented Interfaces:

org.alfresco.reindexing.readers.PageReadFailureListener

public class DlqPageReadFailureListener
extends Object
implements org.alfresco.reindexing.readers.PageReadFailureListener

Bridges page-level read failures (a bad row in a JDBC page fails the whole page — see reindexing AbstractAlfrescoNodeReader) into DlqWriter as a READER record keyed by the failed time window. The reader has already swallowed the failure and advanced the cursor past the window; this listener's only job is to leave an operator-visible trail so the incident isn't silent.

Not registered when the DLQ config is disabled — with no listener bean the reindexing reader rethrows the page exception.

Constructor Summary

Constructors

Constructor	Description
DlqPageReadFailureListener(DlqWriter dlqWriter)

Method Summary

Modifier and Type	Method	Description
void	onPageReadFailure(String readerName, org.alfresco.database.connector.NodeParams params, Throwable cause)

Methods inherited from class java.lang.Object

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

Constructor Details

DlqPageReadFailureListener

public DlqPageReadFailureListener(DlqWriter dlqWriter)

Method Details

onPageReadFailure

public void onPageReadFailure(String readerName,
 org.alfresco.database.connector.NodeParams params,
 Throwable cause)

Specified by:

onPageReadFailure in interface org.alfresco.reindexing.readers.PageReadFailureListener