Skip to content

Commit c3b09f9

Browse files
committed
Refactor/rename queue flush command
1 parent f788d1b commit c3b09f9

File tree

1 file changed

+7
-7
lines changed
  • src/InEngine.Core/Queue/Commands

1 file changed

+7
-7
lines changed

src/InEngine.Core/Queue/Commands/Flush.cs

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -6,27 +6,27 @@ namespace InEngine.Core.Queue.Commands
66
public class Flush : AbstractCommand
77
{
88
[Option("pending", HelpText = "Clear the pending queue.")]
9-
public bool ClearPendingQueue { get; set; }
9+
public bool PendingQueue { get; set; }
1010

1111
[Option("failed", HelpText = "Clear the failed queue.")]
12-
public bool ClearFailedQueue { get; set; }
12+
public bool FailedQueue { get; set; }
1313

1414
[Option("in-progress", HelpText = "Clear the in-progress queue.")]
15-
public bool ClearInProgressQueue { get; set; }
15+
public bool InProgressQueue { get; set; }
1616

1717
[Option("secondary", HelpText = "Clear secondary queues. Primary queues are cleared by default.")]
1818
public bool UseSecondaryQueue { get; set; }
1919

2020
public override void Run()
2121
{
22-
if (ClearPendingQueue == false && ClearFailedQueue == false && ClearInProgressQueue == false)
22+
if (PendingQueue == false && FailedQueue == false && InProgressQueue == false)
2323
throw new CommandFailedException("Must specify at least one queue to clear. Use -h to see available options.");
2424
var broker = Broker.Make(UseSecondaryQueue);
25-
if (ClearPendingQueue)
25+
if (PendingQueue)
2626
Info($"Pending: {broker.ClearPendingQueue().ToString()}");
27-
if (ClearInProgressQueue)
27+
if (InProgressQueue)
2828
Info($"In-progress: {broker.ClearInProgressQueue().ToString()}");
29-
if (ClearFailedQueue)
29+
if (FailedQueue)
3030
Info($"Failed: {broker.ClearFailedQueue().ToString()}");
3131
}
3232
}

0 commit comments

Comments
 (0)