| 123456789101112131415161718192021222324252627 |
- using System;
- using System.IO.Abstractions;
- using BO.ProcessServer.Business.StatisticCounters;
- using BO.ProcessServer.Business.Workers.Contexts;
- using Connector.PS;
- using Quadarax.Foundation.Core.Logging;
- using Quadarax.Foundation.Core.Thread;
- namespace BO.ProcessServer.Business.Workers
- {
- internal class PullDocumentsWorker : LoopWorker
- {
- private const string CS_WK_NAME = "PullDocument";
- public PullDocumentsWorker(Connection connection, TimeSpan loopEveryTimeSpan, IFileSystem fileSystem, Statistics statistics,Pool pool, ILogger logger) : base(CS_WK_NAME, new PullCtx(connection, fileSystem, statistics, pool), logger)
- {
- IterationsDelayBetween = loopEveryTimeSpan;
- }
- public PullDocumentsWorker(string workerName) : base(workerName)
- {
- }
- public PullDocumentsWorker(string workerName, IWorkerContext context, ILogger logger = null) : base(workerName, context, logger)
- {
- }
- }
- }
|