org.ametys.plugins.extraction.execution.pipeline.impl

Class PipelineImpl

java.lang.Object

org.ametys.plugins.extraction.execution.pipeline.impl.PipelineImpl

All Implemented Interfaces:

Closeable, AutoCloseable, Pipeline

class PipelineImpl
extends Object
implements Pipeline

Field Summary

Fields

Modifier and Type	Field and Description
private static Logger	__AVALON_LOGGER
private static Logger	__LOGGER
private PipelineDescriptor	_desc
private TransformerHandler	_firstHandler
private List<InputStream>	_is
private TransformerHandler	_lastHandler
private OutputStream	_out
private SourceResolver	_resolver
private PipelineSerializer	_serializer
private List<Source>	_sources

Constructor Summary

Constructors

Constructor and Description
PipelineImpl(PipelineDescriptor desc, OutputStream out, SourceResolver resolver)

Method Summary

Modifier and Type	Method and Description
private void	_checkExists(Source s, String uri)
private void	_getTransformerHandler(SAXTransformerFactory stf)
private TransformerHandler	_newTransformerHandler(SAXTransformerFactory stf, Source source)
private void	_release()
void	close()
ContentHandler	getHandler() Prepare and gets the ContentHandler for this pipeline.
void	serialize() Serializes this pipeline.

Methods inherited from class java.lang.Object

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

Field Detail

__LOGGER

private static final Logger __LOGGER

__AVALON_LOGGER

private static final Logger __AVALON_LOGGER

_desc

private PipelineDescriptor _desc

_out

private OutputStream _out

_resolver

private SourceResolver _resolver

_sources

private List<Source> _sources

_is

private List<InputStream> _is

_firstHandler

private TransformerHandler _firstHandler

_lastHandler

private TransformerHandler _lastHandler

_serializer

private PipelineSerializer _serializer

Constructor Detail

PipelineImpl

PipelineImpl(PipelineDescriptor desc,
             OutputStream out,
             SourceResolver resolver)

Method Detail

getHandler

public ContentHandler getHandler()
                          throws Exception

Description copied from interface: Pipeline

Prepare and gets the ContentHandler for this pipeline.

Specified by:

getHandler in interface Pipeline

Returns:

the ContentHandler

Throws:

Exception - if an error occured

_getTransformerHandler

private void _getTransformerHandler(SAXTransformerFactory stf)

_newTransformerHandler

private TransformerHandler _newTransformerHandler(SAXTransformerFactory stf,
                                                  Source source)
                                           throws SourceNotFoundException,
                                                  IOException,
                                                  TransformerConfigurationException

Throws:

SourceNotFoundException

IOException

TransformerConfigurationException

_checkExists

private void _checkExists(Source s,
                          String uri)

serialize

public void serialize()
               throws Exception

Description copied from interface: Pipeline

Serializes this pipeline.
Pipeline.getHandler() method must have been called before, and the ContentHandler must no longer receive any event.
Then, the pipeline must be closed.

Specified by:

serialize in interface Pipeline

Throws:

Exception - if an error occured

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

_release

private void _release()
               throws IOException

Throws:

IOException