Added CommandStartedEvent
This commit is contained in:
parent
a3961ffb69
commit
a86c131761
|
@ -0,0 +1,12 @@
|
||||||
|
namespace NzbDrone.Common.Messaging
|
||||||
|
{
|
||||||
|
public class CommandExecutedEvent : IEvent
|
||||||
|
{
|
||||||
|
public ICommand Command { get; private set; }
|
||||||
|
|
||||||
|
public CommandExecutedEvent(ICommand command)
|
||||||
|
{
|
||||||
|
Command = command;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
|
@ -1,10 +1,10 @@
|
||||||
namespace NzbDrone.Common.Messaging
|
namespace NzbDrone.Common.Messaging
|
||||||
{
|
{
|
||||||
public class CommandExecutedEvent : IEvent
|
public class CommandStartedEvent : IEvent
|
||||||
{
|
{
|
||||||
public ICommand Command { get; private set; }
|
public ICommand Command { get; private set; }
|
||||||
|
|
||||||
public CommandExecutedEvent(ICommand command)
|
public CommandStartedEvent(ICommand command)
|
||||||
{
|
{
|
||||||
Command = command;
|
Command = command;
|
||||||
}
|
}
|
||||||
|
|
|
@ -60,7 +60,6 @@ namespace NzbDrone.Common.Messaging
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
private static string GetEventName(Type eventType)
|
private static string GetEventName(Type eventType)
|
||||||
{
|
{
|
||||||
if (!eventType.IsGenericType)
|
if (!eventType.IsGenericType)
|
||||||
|
@ -71,7 +70,6 @@ namespace NzbDrone.Common.Messaging
|
||||||
return string.Format("{0}<{1}>", eventType.Name.Remove(eventType.Name.IndexOf('`')), eventType.GetGenericArguments()[0].Name);
|
return string.Format("{0}<{1}>", eventType.Name.Remove(eventType.Name.IndexOf('`')), eventType.GetGenericArguments()[0].Name);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
public void PublishCommand<TCommand>(TCommand command) where TCommand : class, ICommand
|
public void PublishCommand<TCommand>(TCommand command) where TCommand : class, ICommand
|
||||||
{
|
{
|
||||||
Ensure.That(() => command).IsNotNull();
|
Ensure.That(() => command).IsNotNull();
|
||||||
|
@ -88,6 +86,7 @@ namespace NzbDrone.Common.Messaging
|
||||||
|
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
|
PublishEvent(new CommandStartedEvent(command));
|
||||||
handler.Execute(command);
|
handler.Execute(command);
|
||||||
sw.Stop();
|
sw.Stop();
|
||||||
PublishEvent(new CommandCompletedEvent(command));
|
PublishEvent(new CommandCompletedEvent(command));
|
||||||
|
|
Loading…
Reference in New Issue