tedkulp/Readarr
1
0
Fork 0
mirror of https://github.com/Readarr/Readarr.git synced 2026-04-18 21:34:28 -04:00
Code Issues Projects Releases Wiki Activity

fixed disk scan scheduler.

Browse Source
This commit is contained in:
kay.one
2013-05-12 19:52:55 -07:00
parent 42849d3276
commit 687f8d9384
23 changed files with 140 additions and 142 deletions
Download Patch File Download Diff File Expand all files Collapse all files
NzbDrone.Common/Messaging/IMessageAggregator.cs
+3 -2
View File
@@ -5,7 +5,8 @@
/// </summary>
public interface IMessageAggregator
{
void PublishEvent<TEvent>(TEvent @event) where TEvent : IEvent;
void PublishCommand<TCommand>(TCommand command) where TCommand : ICommand;
void PublishEvent<TEvent>(TEvent @event) where TEvent : class, IEvent;
void PublishCommand<TCommand>(TCommand command) where TCommand : class, ICommand;
void PublishCommand(string commandType);
}
}
NzbDrone.Common/Messaging/MessageAggregator.cs
+20 -3
View File
@@ -1,8 +1,11 @@
using System;
using System.Linq;
using System.Reflection;
using System.Threading.Tasks;
using NLog;
using NzbDrone.Common.Composition;
using NzbDrone.Common.EnsureThat;
using NzbDrone.Common.Serializer;
namespace NzbDrone.Common.Messaging
{
@@ -18,8 +21,10 @@ namespace NzbDrone.Common.Messaging
_serviceFactory = serviceFactory;
}
public void PublishEvent<TEvent>(TEvent @event) where TEvent : IEvent
public void PublishEvent<TEvent>(TEvent @event) where TEvent : class ,IEvent
{
Ensure.That(() => @event).IsNotNull();
var eventName = GetEventName(@event.GetType());
_logger.Trace("Publishing {0}", eventName);
@@ -63,8 +68,10 @@ namespace NzbDrone.Common.Messaging
}
public void PublishCommand<TCommand>(TCommand command) where TCommand : ICommand
public void PublishCommand<TCommand>(TCommand command) where TCommand : class, ICommand
{
Ensure.That(() => command).IsNotNull();
var handlerContract = typeof(IExecute<>).MakeGenericType(command.GetType());
_logger.Trace("Publishing {0}", command.GetType().Name);
@@ -75,7 +82,7 @@ namespace NzbDrone.Common.Messaging
try
{
handlerContract.GetMethod("Execute").Invoke(handler, new object[] {command});
handlerContract.GetMethod("Execute").Invoke(handler, new object[] { command });
PublishEvent(new CommandCompletedEvent(command));
}
catch (TargetInvocationException e)
@@ -95,5 +102,15 @@ namespace NzbDrone.Common.Messaging
_logger.Debug("{0} <- {1}", command.GetType().Name, handler.GetType().Name);
}
public void PublishCommand(string commandTypeName)
{
var commandType = _serviceFactory.GetImplementations(typeof(ICommand))
.Single(c => c.FullName.Equals(commandTypeName, StringComparison.InvariantCultureIgnoreCase));
//json.net is better at creating objects
var command = Json.Deserialize("{}", commandType);
PublishCommand((ICommand)command);
}
}
}