//******************************************************************************************************
// LogPublisherInternal.cs - Gbtc
//
// Copyright © 2016, Grid Protection Alliance. All Rights Reserved.
//
// Licensed to the Grid Protection Alliance (GPA) under one or more contributor license agreements. See
// the NOTICE file distributed with this work for additional information regarding copyright ownership.
// The GPA licenses this file to you under the Eclipse Public License -v 1.0 (the "License"); you may
// not use this file except in compliance with the License. You may obtain a copy of the License at:
//
// http://www.opensource.org/licenses/eclipse-1.0.php
//
// Unless agreed to in writing, the subject software distributed under the License is distributed on an
// "AS-IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. Refer to the
// License for the specific language governing permissions and limitations.
//
// Code Modification History:
// ----------------------------------------------------------------------------------------------------
// 10/24/2016 - Steven E. Chisholm
// Generated original version of source code.
//
//
//******************************************************************************************************
using System;
using System.Collections.Concurrent;
using System.IO;
using System.Reflection;
namespace GSF.Diagnostics
{
///
/// This publisher is shared by all other instances of the same .
///
internal class LogPublisherInternal
{
#region [ Members ]
///
/// Occurs when a new is ready to be published.
///
private LoggerInternal m_logger;
public readonly PublisherTypeDefinition TypeData;
public readonly Type Type;
public readonly Assembly Assembly;
internal MessageAttributeFilterCollection SubscriptionFilterCollection;
#endregion
#region [ Constructors ]
public LogPublisherInternal(LoggerInternal logger, Type type)
{
if ((object)type == null)
throw new ArgumentNullException(nameof(type));
if (type == null)
throw new ArgumentNullException(nameof(type));
if (logger == null)
throw new ArgumentNullException(nameof(logger));
Type = type;
Assembly = type.Assembly;
TypeData = new PublisherTypeDefinition(type);
m_logger = logger;
SubscriptionFilterCollection = new MessageAttributeFilterCollection();
}
#endregion
#region [ Methods ]
///
/// Checks messages generated by this publisher and the provided attributes will be received by a subscriber.
///
///
///
public bool HasSubscribers(LogMessageAttributes attributes)
{
return !m_logger.RoutingTablesValid || SubscriptionFilterCollection.IsSubscribedTo(attributes);
}
#endregion
}
}