0

pollingInterval

using System;
using System.Collections.Generic;
using System.Text;
using Caplin.StreamLink;
using Caplin.StreamLink.Authentication;
using Caplin.StreamLink.Authentication.KeyMaster;
using System.Threading;
using Caplin.StreamLink.Configuration;

namespace StreamLinkExamples.Authentication
{
    class StandardKeyMaster : IExceptionHandler
    {
        public void StandardKeyMasterExample()
        {
            // set up a StreamLink and add a connection listener
            StreamLink myStreamLink = new StreamLink(SimpleConfiguration.CreateType2HttpConnection("myliberatorserver", 80));
            IConnectionListener connectionListener = new ExampleConnectionListener();
            myStreamLink.StreamLinkProvider.AddConnectionListener(connectionListener);

            // add this class as an ExceptionHandler so that we can see any failures
            myStreamLink.ExceptionHandler = this;

            // set up KeyMaster configuration
            String keyMasterURI = "http://mykeymasterserver.mydomain.com:1234/keymaster-basic/servlet/StandardKeyMaster";
            ICredentials keyMasterCredentials = new Credentials("keymasteruser", null);
            myStreamLink.CredentialsProvider = new StandardKeyMasterCredentialsProvider(keyMasterURI, keyMasterCredentials);

            // log in
            myStreamLink.StreamLinkProvider.Connect();
        }

        #region IExceptionHandler Members

        void IExceptionHandler.HandleException(Exception ex)
        {
            string exceptionMessage = ex.InnerException == null ? ex.Message : ex.InnerException.Message;
            Console.WriteLine(exceptionMessage);
        }

        #endregion
    }

    class ExampleConnectionListener : IConnectionListener
    {
        #region IConnectionListener Members

        void IConnectionListener.ConnectionStatusUpdated(IConnectionStatusEvent ev)
        {
            Console.WriteLine("Connection Status Updated: " + ev.Status);
        }

        void IConnectionListener.SourceStatusUpdated(ISourceStatusEvent ev)
        {
            Console.WriteLine("Source Status Updated: " + ev.Name + "=" + ev.Status);
        }

        void IConnectionListener.ServiceStatusUpdated(IServiceStatusEvent ev)
        {
            Console.WriteLine("Service Status Updated: " + ev.Name + "=" + ev.Status);
        }

        #endregion
    }
}