github/lidarr
1
0
Fork 0
mirror of https://github.com/lidarr/lidarr.git synced 2025-08-14 02:37:08 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

removed all the jobs.

Browse source
This commit is contained in:
Keivan Beigi 2013-05-06 17:39:33 -07:00
commit ec58b8b595
42 changed files with 122 additions and 1599 deletions
Download patch file Download diff file Expand all files Collapse all files

14
NzbDrone.Common/Messaging/MessageAggregator.cs
View file

@ -9,20 +9,24 @@ namespace NzbDrone.Common.Messaging
public class MessageAggregator : IMessageAggregator
{
private readonly Logger _logger;
private readonly Func<IEnumerable<IProcessMessage>> _handlers;
private readonly Func<IEnumerable<IProcessMessage>> _handlerFactory;
public MessageAggregator(Logger logger, Func<IEnumerable<IProcessMessage>> handlers)
{
_logger = logger;
_handlers = handlers;
_handlerFactory = handlers;
}
public void PublishEvent<TEvent>(TEvent @event) where TEvent : IEvent
{
_logger.Trace("Publishing {0}", @event.GetType().Name);
var handlers = _handlerFactory().ToList();
//call synchronous handlers first.
foreach (var handler in _handlers().OfType<IHandle<TEvent>>())
foreach (var handler in handlers.OfType<IHandle<TEvent>>())
{
try
{
@ -36,7 +40,7 @@ namespace NzbDrone.Common.Messaging
}
}
foreach (var handler in _handlers().OfType<IHandleAsync<TEvent>>())
foreach (var handler in handlers.OfType<IHandleAsync<TEvent>>())
{
var handlerLocal = handler;
Task.Factory.StartNew(() =>
@ -52,7 +56,7 @@ namespace NzbDrone.Common.Messaging
public void PublishCommand<TCommand>(TCommand command) where TCommand : ICommand
{
_logger.Trace("Publishing {0}", command.GetType().Name);
var handler = _handlers().OfType<IExecute<TCommand>>().Single();
var handler = _handlerFactory().OfType<IExecute<TCommand>>().Single();
_logger.Debug("{0} -> {1}", command.GetType().Name, handler.GetType().Name);
handler.Execute(command);
_logger.Debug("{0} <- {1}", command.GetType().Name, handler.GetType().Name);