Package org.nuxeo.ecm.core.blob.stream

Class StreamOrphanBlobGC.BlobGCComputation

java.lang.Object

org.nuxeo.lib.stream.computation.AbstractComputation

org.nuxeo.ecm.core.blob.stream.StreamOrphanBlobGC.BlobGCComputation

All Implemented Interfaces:

Computation

Enclosing class:

StreamOrphanBlobGC

public static class StreamOrphanBlobGC.BlobGCComputation
extends AbstractComputation

Field Summary

Fields

Modifier and Type	Field	Description
protected Boolean	canDelete
protected Codec<BlobDomainEvent>	codec

Fields inherited from class org.nuxeo.lib.stream.computation.AbstractComputation

INPUT_1, INPUT_2, INPUT_3, INPUT_NULL, metadata, OUTPUT_1, OUTPUT_2, OUTPUT_3, OUTPUT_4

Constructor Summary

Constructors

Constructor	Description
BlobGCComputation(String name)

Method Summary

Modifier and Type	Method	Description
protected boolean	canPerformDelete()
protected DocumentBlobManager	getDocumentBlobManager()
void	processRecord(ComputationContext context, String inputStreamName, Record record)	Process an incoming record on one of the computation's input streams.

Methods inherited from class org.nuxeo.lib.stream.computation.AbstractComputation

init, metadata, processFailure, processRetry, processTimer

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.nuxeo.lib.stream.computation.Computation

destroy, signalStop

Field Detail

codec

protected final Codec<BlobDomainEvent> codec

canDelete

protected Boolean canDelete

Constructor Detail

BlobGCComputation

public BlobGCComputation(String name)

Method Detail

getDocumentBlobManager

protected DocumentBlobManager getDocumentBlobManager()

canPerformDelete

protected boolean canPerformDelete()

processRecord

public void processRecord(ComputationContext context,
                          String inputStreamName,
                          Record record)

Description copied from interface: Computation

Process an incoming record on one of the computation's input streams.

Parameters:

context - The computation context object provided by the system.

inputStreamName - Name of the input stream that provides the record.

record - The record.