实现
AggregationClientServiceImpl
- scanPath: String- fileNameRegex: String - fileNameRegex: String- targetPath: String- syslogKey: int- filesNumThreshold: int- dirStorageThreshold: int- upperWaterMark: int
+ scanTask():Set<String>+ sendTask(): void+ cleanTask(): boolean
依赖
关联
AbstractDataSyncService
+ synchronizeData(): void+ initData(): void
泛化
FtpClient(Basic)
+ openConnection(): void+ closeConnection(): void
AggregationClientManager
- aggregationProducerOption: BasicThreadOption- processService: AggregationProcessService
+ init(): void
BasicThreadOption
- runInterval: long- threadName: String- maxRunPeriod: long- maxTimeoutTimes: long
SftpClientImpl(Basic)
- channel: Channel- deviceCode: long- address: String- path: String
AggregationClientService
+ scanTask(): Set<String>+ sendTask(): void+ cleanTask(): boolean
JdbcBaseDao(Basic)
+set;;+get::
AggregationDeviceSyncServiceImpl
- syncPoolDao: JdbcBaseDao- period: long- dataRepository AggClientRepository- feature: String=\"common\"- devicePool: List<DeviceInfo>
- syncDevicePool(): List<DeviceInfo>+ getPoolDeviceNum: int+ getPoolDeviceInfo(int bucketId): DeviceInfo+ synchronizeData(): void+ initData(): void
JdbcBaseDaoImpl(Basic)
- dataSource: DataSource=emsDataSource
