SyslogEventSink.cs

using System;
using System.Security.Cryptography.X509Certificates;
using System.Threading.Tasks;
using Waher.Security;
 
namespace Waher.Events.Syslog
{
    public class SyslogEventSink : EventSink, ITlsCertificateEndpoint
    {
        private SyslogClient client;
 
        public SyslogEventSink(string Host, int Port, bool Tls, string LocalHostName,
            string AppName, SyslogEventSeparation Separation, string ObjectID)
            : base(ObjectID)
        {
            this.client = new SyslogClient(Host, Port, Tls, LocalHostName, AppName, Separation);
        }
 
        public SyslogEventSink(string Host, int Port, X509Certificate Certificate, 
            string LocalHostName, string AppName, SyslogEventSeparation Separation, 
            string ObjectID)
            : base(ObjectID)
        {
            this.client = new SyslogClient(Host, Port, Certificate, LocalHostName, AppName, Separation);
        }
 
        public override async Task Queue(Event Event)
        {
            try
            {
                await this.client.Send(Event);
            }
            catch (Exception ex)
            {
                Event Event2 = new Event(EventType.Critical, ex, this.ObjectID,
                    string.Empty, string.Empty, EventLevel.Medium, string.Empty,
                    string.Empty);
                Event2.Avoid(this);
 
                Log.Event(Event2);
            }
        }
 
        public override async Task DisposeAsync()
        {
            if (!(this.client is null))
            {
                await this.client.DisposeAsync();
                this.client = null;
            }
 
            await base.DisposeAsync();
        }
 
        public void UpdateCertificate(X509Certificate Certificate)
        {
            this.client.UpdateCertificate(Certificate);
        }
    }
}