<commit_before>﻿using Elders.Cronus.Logging;
using Elders.Cronus.MessageProcessing;
using Elders.Cronus.Multitenancy;
using System;

namespace Elders.Cronus.InMemory
{
    public class SynchronousMessageProcessor<T> : InMemoryPublisher<IMessage> where T : IMessage
    {
        private readonly static ILog log = LogProvider.GetLogger(typeof(SynchronousMessageProcessor<>));

        private readonly ISubscriberCollection<IApplicationService> appServiceSubscribers;
        private readonly ISubscriberCollection<IProjection> projectionSubscribers;
        private readonly ISubscriberCollection<IPort> portSubscribers;
        private readonly ISubscriberCollection<IGateway> gatewaySubscribers;
        private readonly ISubscriberCollection<ISaga> sagaSubscribers;

        public SynchronousMessageProcessor(
            ISubscriberCollection<IApplicationService> appServiceSubscribers,
            ISubscriberCollection<IProjection> projectionSubscribers,
            ISubscriberCollection<IPort> portSubscribers,
            ISubscriberCollection<IGateway> gatewaySubscribers,
            ISubscriberCollection<ISaga> sagaSubscribers)
            : base(new DefaultTenantResolver())
        {
            this.appServiceSubscribers = appServiceSubscribers;
            this.projectionSubscribers = projectionSubscribers;
            this.portSubscribers = portSubscribers;<commit_msg>Fixes a generic type parameter<commit_after>﻿using Elders.Cronus.Logging;
using Elders.Cronus.MessageProcessing;
using Elders.Cronus.Multitenancy;
using System;

namespace Elders.Cronus.InMemory
{
    public class SynchronousMessageProcessor<T> : InMemoryPublisher<T> where T : IMessage
    {
        private readonly static ILog log = LogProvider.GetLogger(typeof(SynchronousMessageProcessor<>));

        private readonly ISubscriberCollection<IApplicationService> appServiceSubscribers;
        private readonly ISubscriberCollection<IProjection> projectionSubscribers;
        private readonly ISubscriberCollection<IPort> portSubscribers;
        private readonly ISubscriberCollection<IGateway> gatewaySubscribers;
        private readonly ISubscriberCollection<ISaga> sagaSubscribers;

        public SynchronousMessageProcessor(
            ISubscriberCollection<IApplicationService> appServiceSubscribers,
            ISubscriberCollection<IProjection> projectionSubscribers,
            ISubscriberCollection<IPort> portSubscribers,
            ISubscriberCollection<IGateway> gatewaySubscribers,
            ISubscriberCollection<ISaga> sagaSubscribers)
            : base(new DefaultTenantResolver())
        {
            this.appServiceSubscribers = appServiceSubscribers;
            this.projectionSubscribers = projectionSubscribers;
            this.portSubscribers = portSubscribers;
{'fraction_non_alphanumeric': 0.05654974946313529, 'fraction_numerical': 0.0, 'mean_word_length': 4.1855287569573285, 'pattern_counts': {'":': 0, '<': 29, '<?xml version=': 0, '>': 29, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '3952939', 'n_tokens_mistral': 723, 'n_tokens_neox': 705, 'n_words': 129}