org.nuxeo.ecm.platform.replication.exporter

Class ReplicationPipe

java.lang.Object

org.nuxeo.ecm.core.io.impl.DocumentPipeImpl

org.nuxeo.ecm.platform.replication.exporter.ReplicationPipe

All Implemented Interfaces:

DocumentPipe

public class ReplicationPipe
extends DocumentPipeImpl

Extension of basic DocumentPipeImpl to allow multithreading

Author:

cpriceputu@nuxeo.com

Constructor Summary

Constructors

Constructor and Description
ReplicationPipe()
ReplicationPipe(int pageSize)

Method Summary

Methods

Modifier and Type	Method and Description
StatusListener	getListener()
boolean	isRunning()
DocumentTranslationMap	run()
void	setListener(StatusListener listener)
void	stop()

Methods inherited from class org.nuxeo.ecm.core.io.impl.DocumentPipeImpl

addTransformer, applyTransforms, applyTransforms, getReader, getTransformers, getWriter, removeTransformer, setReader, setWriter

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationPipe

public ReplicationPipe(int pageSize)

ReplicationPipe

public ReplicationPipe()

Method Detail

stop

public void stop()

isRunning

public boolean isRunning()

run

public DocumentTranslationMap run()
                           throws Exception

Specified by:

run in interface DocumentPipe

Overrides:

run in class DocumentPipeImpl

Throws:

Exception

setListener

public void setListener(StatusListener listener)

getListener

public StatusListener getListener()