Create a .NET client within minutes that connects to Diffusion™ Cloud. This example creates a client that prints the value of a JSON topic to the console when the topic is updated.

1. Create a .NET project that references the DLL file that can be downloaded from the following location: Download the .NET assembly

   PushTechnology.ClientInterface.dll

   The assembly contains the interface classes and interfaces that you use when creating a control client.

   The .NET assembly is also available through NuGet.

   Use the following command in the NuGet Package Manager Console:

   PM> Install-Package PushTechnology.UnifiedClientInterface

2. In your project, create a C# file that uses the following packages:

   using System;
   using System.Threading;
   using PushTechnology.ClientInterface.Client.Callbacks;
   using PushTechnology.ClientInterface.Client.Factories;
   using PushTechnology.ClientInterface.Client.Features;
   using PushTechnology.ClientInterface.Client.Features.Topics;
   using PushTechnology.ClientInterface.Client.Topics.Details;
   using PushTechnology.ClientInterface.Data.JSON;
   
   namespace PushTechnology.ClientInterface.GettingStarted {
       public sealed class SubscribingClient {
       
       }
   }

3. Create a Main method.

       public sealed class SubscribingClient
       {
           public static void Main( string[] args ) {
        
           }
       }

4. In the Main method, connect to Diffusion Cloud.

           public static void Main( string[] args ) {
               // Connect anonymously
               // Replace 'host' with your hostname
               var session = Diffusion.Sessions.Open("ws://host:80");
             }

   Or you can connect securely, using Secure Sockets Layer (SSL):

               Session session = Diffusion.sessions().Open("wss://host:443");

   Or you can connect with a principal and credentials if that principal is assigned a role with the read_topic permission:

               Session session = Diffusion.Sessions().Principal("principal")
               .Password("password").Open("wss://host:443");

   Replace the host, principal, and password values with your own information.
5. Next, in the Main method, get the Topics feature.

           // Get the Topics feature to subscribe to topics
             var topics = session.GetTopicsFeature();

   The Topics feature enables a client to subscribe to a topic or fetch its state.
6. Within the subscribing client class, create an inner class that implements IValueStream for a JSON topic.
   This inner class defines the behavior that occurs when a topic that the client subscribes to is updated. In this example, the topic stream prints the topic name and the content of the update to the console.

         /// <summary>
             /// Basic implementation of the IValueStream<TValue> for JSON topics.
             /// </summary>
             internal sealed class JSONStream : IValueStream<IJSON> {
             
             /// <summary>
             /// Notification of stream being closed normally.
             /// </summary>
             public void OnClose() {
               Console.WriteLine( "The subscrption stream is now closed." );
             }
             
             /// <summary>
             /// Notification of a contextual error related to this callback.
             /// </summary>
             /// <remarks>
             /// Situations in which <code>OnError</code> is called include the session being closed, a communication
             /// timeout, or a problem with the provided parameters. No further calls will be made to this callback.
             /// </remarks>
             /// <param name="errorReason">Error reason.</param>
             public void OnError( ErrorReason errorReason ) {
               Console.WriteLine( "An error has occured : {0}", errorReason );
             }
         
             /// <summary>
             /// Notification of a successful subscription.
             /// </summary>
             /// <param name="topicPath">Topic path.</param>
             /// <param name="specification">Topic specification.</param>
             public void OnSubscription( string topicPath, ITopicSpecification specification ) {
               Console.WriteLine( "Client subscribed to {0} ", topicPath );
             }
             
             /// <summary>
             /// Notification of a successful unsubscription.
             /// </summary>
             /// <param name="topicPath">Topic path.</param>
             /// <param name="specification">Topic specification.</param>
             /// <param name="reason">Error reason.</param>
             public void OnUnsubscription( string topicPath, ITopicSpecification specification, TopicUnsubscribeReason reason ) {
               Console.WriteLine( "Client unsubscribed from {0} : {1}", topicPath, reason );
             }
             
             /// <summary>
             /// Topic update received.
             /// </summary>
             /// <param name="topicPath">Topic path.</param>
             /// <param name="specification">Topic specification.</param>
             /// <param name="oldValue">Value prior to update.</param>
             /// <param name="newValue">Value after update.</param>
             public void OnValue( string topicPath, ITopicSpecification specification, IJSON oldValue, IJSON newValue ) {
               Console.WriteLine( "New value of {0} is {1}", topicPath, newValue.ToJSONString() );
             }
       

7. Back in the Main method of the subscribing client class, use the AddStream method to associate an instance of the topic stream that you created with the topic you want to subscribe to. In this example, the topic path is "foo/counter".

             var topic = ">foo/counter";
             // Add a topic stream for 'foo/counter' and request subscription
             var jsonStream = new JSONStream();
             topics.AddStream( topic, jsonStream );
             topics.Subscribe( topic, new TopicsCompletionCallbackDefault() );

8. Use a Thread.sleep() to hold the client open for 10 minutes while the updates are received and output.

             //Stay connected for 10 minutes
             Thread.Sleep( TimeSpan.FromMinutes( 10 ) );
           
             session.Close();

9. Compile and run your client.

using System;
using System.Threading;
using PushTechnology.ClientInterface.Client.Callbacks;
using PushTechnology.ClientInterface.Client.Factories;
using PushTechnology.ClientInterface.Client.Features;
using PushTechnology.ClientInterface.Client.Features.Topics;
using PushTechnology.ClientInterface.Client.Topics.Details;
using PushTechnology.ClientInterface.Data.JSON;

namespace PushTechnology.ClientInterface.GettingStarted {
    /// <summary>
    /// A client that subscribes to the topic 'foo/counter'.
    /// </summary>
    public sealed class SubscribingClient {
        public static void Main( string[] args ) {
            // Connect anonymously
            var session = Diffusion.Sessions.Open( "ws://localhost:8080" );

            // Get the Topics feature to subscribe to topics
            var topics = session.GetTopicsFeature();

            var topic = ">foo/counter";
            // Add a topic stream for 'foo/counter' and request subscription
            var jsonStream = new JSONStream();
            topics.AddStream( topic, jsonStream );
            topics.Subscribe( topic, new TopicsCompletionCallbackDefault() );

            //Stay connected for 10 minutes
            Thread.Sleep( TimeSpan.FromMinutes( 10 ) );

            session.Close();
        }
    }

    /// <summary>
    /// Basic implementation of the IValueStream<TValue> for JSON topics.
    /// </summary>
    internal sealed class JSONStream : IValueStream<IJSON> {

        /// <summary>
        /// Notification of stream being closed normally.
        /// </summary>
        public void OnClose() {
            Console.WriteLine( "The subscrption stream is now closed." );
        }

        /// <summary>
        /// Notification of a contextual error related to this callback.
        /// </summary>
        /// <remarks>
        /// Situations in which <code>OnError</code> is called include the session being closed, a communication
        /// timeout, or a problem with the provided parameters. No further calls will be made to this callback.
        /// </remarks>
        /// <param name="errorReason">Error reason.</param>
        public void OnError( ErrorReason errorReason ) {
            Console.WriteLine( "An error has occured : {0}", errorReason );
        }

        /// <summary>
        /// Notification of a successful subscription.
        /// </summary>
        /// <param name="topicPath">Topic path.</param>
        /// <param name="specification">Topic specification.</param>
        public void OnSubscription( string topicPath, ITopicSpecification specification ) {
            Console.WriteLine( "Client subscribed to {0} ", topicPath );
        }

        /// <summary>
        /// Notification of a successful unsubscription.
        /// </summary>
        /// <param name="topicPath">Topic path.</param>
        /// <param name="specification">Topic specification.</param>
        /// <param name="reason">Error reason.</param>
        public void OnUnsubscription( string topicPath, ITopicSpecification specification, TopicUnsubscribeReason reason ) {
            Console.WriteLine( "Client unsubscribed from {0} : {1}", topicPath, reason );
        }

        /// <summary>
        /// Topic update received.
        /// </summary>
        /// <param name="topicPath">Topic path.</param>
        /// <param name="specification">Topic specification.</param>
        /// <param name="oldValue">Value prior to update.</param>
        /// <param name="newValue">Value after update.</param>
        public void OnValue( string topicPath, ITopicSpecification specification, IJSON oldValue, IJSON newValue ) {
            Console.WriteLine( "New value of {0} is {1}", topicPath, newValue.ToJSONString() );
        }
    }
}