@ComponentProfile(summary="Allows you to aggregate messages from an FTP server", tag="service,aggregation,ftp", recommended=FileTransferConnection.class) public class AggregatingFtpConsumeService extends AggregatingConsumeServiceImpl<FileTransferConnection> implements ConnectedService
AggregatingConsumeService
that allows you to consume a related
message via FTP based on some criteria.In the adapter configuration file this class is aliased as aggregating-ftp-consume-service which is the preferred alternative to the fully qualified classname when building your configuration.
log
CONFIRMATION_ID_KEY
Constructor and Description |
---|
AggregatingFtpConsumeService() |
AggregatingFtpConsumeService(AdaptrisConnection conn,
AggregatingFtpConsumer consumer) |
Modifier and Type | Method and Description |
---|---|
void |
doService(AdaptrisMessage msg)
Apply the service to the message.
|
AdaptrisConnection |
getConnection()
Returns the
AdaptrisConnection to use. |
AggregatingFtpConsumer |
getConsumer() |
protected void |
initService() |
void |
prepare()
Prepare for initialisation.
|
void |
setConnection(AdaptrisConnection connection)
Sets the
AdaptrisConnection to use. |
void |
setConsumer(AggregatingFtpConsumer fsConsumer) |
closeService, start, start, stop, stop
changeState, close, continueOnFailure, createName, createQualifier, getContinueOnFail, getIsTrackingEndpoint, getLookupName, getUniqueId, init, isBranching, isTrackingEndpoint, requestClose, requestInit, requestStart, requestStop, retrieveComponentState, setContinueOnFail, setIsTrackingEndpoint, setLookupName, setUniqueId
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
continueOnFailure, isBranching, setUniqueId
createName, createQualifier, isTrackingEndpoint
changeState, requestClose, requestInit, requestStart, requestStop, retrieveComponentState
getUniqueId
close, init, start, stop
getLookupName
public AggregatingFtpConsumeService()
public AggregatingFtpConsumeService(AdaptrisConnection conn, AggregatingFtpConsumer consumer)
protected void initService() throws CoreException
initService
in class AggregatingConsumeServiceImpl<FileTransferConnection>
CoreException
public void doService(AdaptrisMessage msg) throws ServiceException
Service
Apply the service to the message.
doService
in interface Service
msg
- the AdaptrisMessage
to processServiceException
- wrapping any underlying Exception
spublic AggregatingFtpConsumer getConsumer()
public void setConsumer(AggregatingFtpConsumer fsConsumer)
fsConsumer
- the fsConsumer to setpublic void prepare() throws CoreException
ComponentLifecycleExtension
prepare
in interface ComponentLifecycleExtension
CoreException
public AdaptrisConnection getConnection()
ConnectedService
AdaptrisConnection
to use.getConnection
in interface ConnectedService
AdaptrisConnection
public void setConnection(AdaptrisConnection connection)
ConnectedService
AdaptrisConnection
to use.setConnection
in interface ConnectedService
connection
- the AdaptrisConnection
to use