Skip to content

Commit 2296091

Browse files
more trace
1 parent ef8b6f1 commit 2296091

1 file changed

Lines changed: 7 additions & 3 deletions

File tree

FileProcessor/FileProcessingWorker.cs

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -79,17 +79,21 @@ public override async Task StartAsync(CancellationToken cancellationToken)
7979
{
8080
// TODO: Do we poll here for files incase they have been left from a previous run
8181
var temporaryFileLocation = ConfigurationReader.GetValue("AppSettings", "TemporaryFileLocation");
82+
this.LogInformation($"Starting up, TemporaryFileLocation is [{temporaryFileLocation}]");
8283
Directory.CreateDirectory(temporaryFileLocation);
84+
this.LogInformation($"Created TemporaryFileLocation at [{temporaryFileLocation}]");
8385
var fileProfiles = await this.FileProcessorManager.GetAllFileProfiles(cancellationToken);
8486

8587
foreach (FileProfile fileProfile in fileProfiles)
8688
{
8789
Directory.CreateDirectory($"{fileProfile.ListeningDirectory}//inprogress");
90+
this.LogInformation($"Created in progress at [{ fileProfile.ListeningDirectory}//inprogress");
8891
Directory.CreateDirectory(fileProfile.ProcessedDirectory);
92+
this.LogInformation($"Created ProcessedDirectory at [{fileProfile.ProcessedDirectory}]");
8993
Directory.CreateDirectory(fileProfile.FailedDirectory);
94+
this.LogInformation($"Created FailedDirectory at [{fileProfile.FailedDirectory}]");
9095
}
9196

92-
9397
await base.StartAsync(cancellationToken);
9498
}
9599

@@ -126,12 +130,12 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
126130
var fileProfiles = await this.FileProcessorManager.GetAllFileProfiles(stoppingToken);
127131
foreach (FileProfile fileProfile in fileProfiles)
128132
{
129-
this.LogDebug($"About to look in {fileProfile.ListeningDirectory} for files");
133+
this.LogInformation($"About to look in {fileProfile.ListeningDirectory} for files");
130134
var files = Directory.GetFiles(fileProfile.ListeningDirectory).Take(1).ToList(); // Only process 1 file per file profile concurrently
131135

132136
foreach (String file in files)
133137
{
134-
this.LogDebug($"File {file} detected");
138+
this.LogInformation($"File {file} detected");
135139
var request = this.CreateProcessFileRequest(fileProfile, file);
136140
fileProcessingTasks.Add(this.Mediator.Send(request));
137141
}

0 commit comments

Comments
 (0)