Package org.alfresco.elasticsearch.batchindexing.cascade

Class CascadeCollectorWriter

java.lang.Object

org.alfresco.elasticsearch.batchindexing.cascade.CascadeCollectorWriter

All Implemented Interfaces:

org.springframework.batch.infrastructure.item.ItemWriter<org.alfresco.reindexing.model.ReindexingEvent>

public class CascadeCollectorWriter
extends Object
implements org.springframework.batch.infrastructure.item.ItemWriter<org.alfresco.reindexing.model.ReindexingEvent>

Observer ItemWriter that scans events for cascade signals and stashes enriched sources for the post-cycle sweep. Must run first in the composite writer so mgets capture the ES doc before it is overwritten.

Detects renames (non-delete event with sys:cascadeTx) and category deletes (delete event whose pre-delete ES doc has TYPE == cm:category — the event's own type is unreliable, ACS flips it to sys:deleted).

Constructor Summary

Constructors

Constructor	Description
CascadeCollectorWriter(CascadeSourceStash stash, SourceDocLookup sourceDocLookup)

Method Summary

Modifier and Type	Method	Description
void	write(org.springframework.batch.infrastructure.item.Chunk<? extends org.alfresco.reindexing.model.ReindexingEvent> chunk)

Methods inherited from class java.lang.Object

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

Constructor Details

CascadeCollectorWriter

public CascadeCollectorWriter(CascadeSourceStash stash,
 SourceDocLookup sourceDocLookup)

Method Details

write

public void write(org.springframework.batch.infrastructure.item.Chunk<? extends org.alfresco.reindexing.model.ReindexingEvent> chunk)

Specified by:

write in interface org.springframework.batch.infrastructure.item.ItemWriter<org.alfresco.reindexing.model.ReindexingEvent>