Fixed: Broken tasks getting stuck in queue

pull/4222/head
Mark McDowall 5 years ago committed by Qstick
parent 5b6a6cc9dc
commit fd3acd85e6

@ -66,14 +66,16 @@ namespace NzbDrone.Core.Messaging.Commands
private void ExecuteCommand<TCommand>(TCommand command, CommandModel commandModel) private void ExecuteCommand<TCommand>(TCommand command, CommandModel commandModel)
where TCommand : Command where TCommand : Command
{
IExecute<TCommand> handler = null;
try
{ {
var handlerContract = typeof(IExecute<>).MakeGenericType(command.GetType()); var handlerContract = typeof(IExecute<>).MakeGenericType(command.GetType());
var handler = (IExecute<TCommand>)_serviceFactory.Build(handlerContract); handler = (IExecute<TCommand>)_serviceFactory.Build(handlerContract);
_logger.Trace("{0} -> {1}", command.GetType().Name, handler.GetType().Name); _logger.Trace("{0} -> {1}", command.GetType().Name, handler.GetType().Name);
try
{
_commandQueueManager.Start(commandModel); _commandQueueManager.Start(commandModel);
BroadcastCommandUpdate(commandModel); BroadcastCommandUpdate(commandModel);
@ -108,10 +110,13 @@ namespace NzbDrone.Core.Messaging.Commands
{ {
ProgressMessageContext.CommandModel = null; ProgressMessageContext.CommandModel = null;
} }
}
if (handler != null)
{
_logger.Trace("{0} <- {1} [{2}]", command.GetType().Name, handler.GetType().Name, commandModel.Duration.ToString()); _logger.Trace("{0} <- {1} [{2}]", command.GetType().Name, handler.GetType().Name, commandModel.Duration.ToString());
} }
}
}
private void BroadcastCommandUpdate(CommandModel command) private void BroadcastCommandUpdate(CommandModel command)
{ {

Loading…
Cancel
Save