public class FilePollingConsumer extends Object
Constructor and Description |
---|
FilePollingConsumer(Properties vfsProperties,
String name,
org.apache.synapse.core.SynapseEnvironment synapseEnvironment,
long scanInterval) |
Modifier and Type | Method and Description |
---|---|
void |
execute()
This will be called by the task scheduler.
|
protected Properties |
getInboundProperties() |
org.apache.commons.vfs2.FileObject |
poll()
Do the file processing operation for the given set of properties.
|
void |
registerHandler(FileInjectHandler injectHandler)
Register a handler to process the file stream after reading from the
source
|
public FilePollingConsumer(Properties vfsProperties, String name, org.apache.synapse.core.SynapseEnvironment synapseEnvironment, long scanInterval)
public void registerHandler(FileInjectHandler injectHandler)
injectHandler
- public void execute()
public org.apache.commons.vfs2.FileObject poll()
protected Properties getInboundProperties()
Copyright © 2022 WSO2. All rights reserved.