using System;
using System.Collections.Generic;
using System.Text;
using Caplin.StreamLink;
using Caplin.StreamLink.Authentication;
using Caplin.StreamLink.Subscription.Record;

namespace StreamLinkExamples.Record
{
    /// <summary>
    /// Various examples of how to create an IRecordSubscription using the
    /// IStreamLinkProvider interface.
    /// </summary>
    public class CreateRecordSubscriptionWithFields
    {
        /// <summary>
        /// Creates a simple record subscription with no parameters.
        /// </summary>
        public static void CreateRecordSubscriptionWithFieldsExample()
        {
            // Set up StreamLink and login credentials
            IStreamLink myStreamLink = new StreamLink();
            myStreamLink.CredentialsProvider =
                new PasswordCredentialsProvider("admin", "admin");

            // Set up listener and created the subscription for /DEMO/MSFT
            IRecordSubscriptionListener listener =
                new ExampleRecordSubscriptionListener();

            string[] fields = new string[] { "Bid", "Ask" };
            IRecordSubscriptionParameters parameters = myStreamLink.StreamLinkProvider.ParametersFactory.CreateRecordSubscriptionParameters(fields);

            // Create subscription, specifying fields Bid and Ask
            IRecordSubscription subscription =
                myStreamLink.StreamLinkProvider.CreateRecordSubscription(listener, "/DEMO/MSFT", parameters);

            // Subscribe the subscription, this will be queued until we
            // login to the Liberator
            subscription.Subscribe();

            // Finally, connect to the Liberator
            myStreamLink.StreamLinkProvider.Connect();
        }
    }
}

using System;

using Caplin.StreamLink;
using Caplin.StreamLink.Authentication;
using Caplin.StreamLink.Subscription.Directory;

namespace StreamLinkExamples.Directory
{
    /// <summary>
    /// Example of how to create a directory subscription using parameters.
    /// </summary>
    public class CreateDirectorySubscriptionWithParameters
    {
        /// <summary>
        /// Creates a simple directory subscription with no parameters.
        /// </summary>
        public static void CreateADirectorySubscriptionWithParametersExample()
        {
            // Set up StreamLink and login credentials
            IStreamLink myStreamLink = new StreamLink();
            myStreamLink.CredentialsProvider =
                new PasswordCredentialsProvider("admin", "admin");

            // Finally, connect to the Liberator
            myStreamLink.StreamLinkProvider.Connect();

            // Set up listener and created the subscription for /DEMO
            IDirectorySubscriptionListener listener =
                new ExampleDirectorySubscriptionListener();

            IDirectorySubscriptionParameters parameters =
                myStreamLink.StreamLinkProvider.ParametersFactory.CreateDirectorySubscriptionParameters();

            IDirectorySubscription subscription =
                myStreamLink.StreamLinkProvider.CreateDirectorySubscription(listener, "/DEMO", parameters);

            // Subscribe the subscription, this will be queued until we
            // login to the Liberator
            subscription.Subscribe();
        }
    }
}

using System;
using System.Collections.Generic;
using System.Text;
using Caplin.StreamLink;
using Caplin.StreamLink.Authentication;
using Caplin.StreamLink.Command;

namespace StreamLinkExamples.Commands
{
    public class PublishToSubject
    {
        /// <summary>
        /// Example of how to create a new Record subject on the Liberator.
        /// </summary>
        public static void PublishToASubjectExample()
        {
            IStreamLink myStreamLink = new StreamLink();
            myStreamLink.CredentialsProvider = new PasswordCredentialsProvider("admin", "admin");

            myStreamLink.StreamLinkProvider.Connect();

            // Identify the fields to be published to and the values to be published.
            Dictionary<string,string> fieldsAndValues = new Dictionary<string,string>();
            fieldsAndValues.Add("Bid", "200");
            fieldsAndValues.Add("Volume", "10000");

            // Create the publish parameters using the fields and their values.
            IPublishParameters publishParameters =
                myStreamLink.StreamLinkProvider.ParametersFactory.CreatePublishParameters(fieldsAndValues);

            // listener called when the command has finished executing
            ICommandListener listener = new ExampleCommandListener();

            // Submit the publish command
            myStreamLink.StreamLinkProvider.Publish(listener, "Subject", publishParameters);
        }
    }
}