Skip to content

Commit 702c1d1

Browse files
committed
Cleanup
1 parent 2ed75ea commit 702c1d1

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

src/InEngine.Core/Queuing/Jobs.cs

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ public void Schedule(Schedule schedule)
1414
ScheduleQueueConsumerJobs(schedule, queueSettings.SecondaryQueueConsumers, true);
1515
}
1616

17-
private void ScheduleQueueConsumerJobs(Schedule schedule, int consumers, bool useSecondaryQueue = false)
17+
void ScheduleQueueConsumerJobs(Schedule schedule, int consumers, bool useSecondaryQueue = false)
1818
{
1919
if (consumers < 0)
2020
throw new ArgumentOutOfRangeException(nameof(consumers), consumers, "The number of queue consumers must be 0 or greater.");
@@ -25,8 +25,7 @@ private void ScheduleQueueConsumerJobs(Schedule schedule, int consumers, bool us
2525
ScheduleId = $"{(useSecondaryQueue ? "secondary" : "primary")}:{index.ToString()}",
2626
UseSecondaryQueue = useSecondaryQueue
2727
})
28-
.EverySecond()
29-
.WriteOutputTo("tmp/somefile");
28+
.EverySecond();
3029
}
3130
}
3231
}

0 commit comments

Comments
 (0)