Package org.alfresco.elasticsearch.batchindexing.listeners

Class DlqSkipListener

java.lang.Object

org.alfresco.elasticsearch.batchindexing.listeners.DlqSkipListener

All Implemented Interfaces:

org.springframework.batch.core.listener.SkipListener<org.alfresco.database.connector.model.AlfrescoNode,org.alfresco.reindexing.model.ReindexingEvent>, org.springframework.batch.core.listener.StepListener

public class DlqSkipListener
extends Object
implements org.springframework.batch.core.listener.SkipListener<org.alfresco.database.connector.model.AlfrescoNode,org.alfresco.reindexing.model.ReindexingEvent>

Bridges Spring Batch skip events into DlqWriter. Typed to SkipListener<AlfrescoNode, ReindexingEvent> because that matches the reindex-by-date step's I/O; the reindexing module's skip-listener hook wires this in via ObjectProvider<SkipListener<?, ?>> so no explicit registration is needed.

Constructor Summary

Constructors

Constructor	Description
DlqSkipListener(DlqWriter dlqWriter)

Method Summary

Modifier and Type	Method	Description
void	onSkipInProcess(org.alfresco.database.connector.model.AlfrescoNode item, Throwable throwable)
void	onSkipInRead(Throwable throwable)
void	onSkipInWrite(org.alfresco.reindexing.model.ReindexingEvent item, Throwable throwable)

Methods inherited from class java.lang.Object

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

Constructor Details

DlqSkipListener

public DlqSkipListener(DlqWriter dlqWriter)

Method Details

onSkipInRead

public void onSkipInRead(Throwable throwable)

Specified by:

onSkipInRead in interface org.springframework.batch.core.listener.SkipListener<org.alfresco.database.connector.model.AlfrescoNode,org.alfresco.reindexing.model.ReindexingEvent>

onSkipInProcess

public void onSkipInProcess(org.alfresco.database.connector.model.AlfrescoNode item,
 Throwable throwable)

Specified by:

onSkipInProcess in interface org.springframework.batch.core.listener.SkipListener<org.alfresco.database.connector.model.AlfrescoNode,org.alfresco.reindexing.model.ReindexingEvent>

onSkipInWrite

public void onSkipInWrite(org.alfresco.reindexing.model.ReindexingEvent item,
 Throwable throwable)

Specified by:

onSkipInWrite in interface org.springframework.batch.core.listener.SkipListener<org.alfresco.database.connector.model.AlfrescoNode,org.alfresco.reindexing.model.ReindexingEvent>