public abstract class AbstractFSConsumer extends FileResourceConsumer
ELAPSED_MILLIS, IO_IS, IO_OS, LOG, OOM, PARSE_ERR, PARSE_EX, TIMED_OUT
Constructor and Description |
---|
AbstractFSConsumer(ArrayBlockingQueue<FileResource> fileQueue) |
Modifier and Type | Method and Description |
---|---|
protected InputStream |
getInputStream(FileResource fileResource) |
protected OutputStream |
getOutputStream(OutputStreamFactory fsOSFactory,
FileResource fileResource)
Use this for consistent logging of exceptions.
|
call, checkForTimedOutMillis, close, flushAndClose, getCurrentFile, getNumHandledExceptions, getNumResourcesConsumed, getXMLifiedLogMsg, getXMLifiedLogMsg, incrementHandledExceptions, isStillActive, parse, pleaseShutdown, processFileResource
public AbstractFSConsumer(ArrayBlockingQueue<FileResource> fileQueue)
protected OutputStream getOutputStream(OutputStreamFactory fsOSFactory, FileResource fileResource)
fsOSFactory
- factory that creates the outputstreamfileResource
- used by the OSFactory to create the streamprotected InputStream getInputStream(FileResource fileResource)
fileResource
- Copyright © 2007–1969 The Apache Software Foundation. All rights reserved.