Skip to main content

Publish Subscribe C#



This is a class which holds the information about the event.  

    public class TimeEventArgs : EventArgs
    {
        public TimeEventArgs(string currentTime)
        {
            this.CurrentTime = currentTime;
        }

        public string CurrentTime;
    }

This is a Subject class (Publisher) that the other classes will observe. So it publishes a handler so that other observer classes can subscribe to it.

    public class Clock
    {
        public delegate void SecondChangeHandler(object clock, TimeEventArgs e);

        public SecondChangeHandler OnSecondChange;

        public void RunClock()
        {
            for (int i = 0; i <= 4; i++)
            {
                Thread.Sleep(1000);

                TimeEventArgs te = new      TimeEventArgs(DateTime.Now.ToString("HH:mm:ss"));

                if (OnSecondChange != null)
                {
                    OnSecondChange(this, te);
                }
            }
        }
    }

This is a Fisrt Observer class which is subscribed to Clock class

    public class DisplayClock
    {
        public void Subscribe(Clock clock)
        {
            clock.OnSecondChange += new Clock.SecondChangeHandler(TimeChanged);
        }

        private void TimeChanged(object clock, TimeEventArgs te)
        {
            Console.WriteLine("Time Changed :: " + te.CurrentTime);
        }
    }


This is a Second Observer class which is subscribed to Clock class

    public class LogClock
    {
        public void Subscribe(Clock clock)
        {
            clock.OnSecondChange += new    Clock.SecondChangeHandler(LogTimeChanged);
        }

        private void LogTimeChanged(object clock, TimeEventArgs te)
        {
            Console.WriteLine("Log Time : " + te.CurrentTime);
        }
    }


Now test the Publish Subscribe

        static void Main(string[] args)
        {
            Clock clock = new Clock();

            DisplayClock dc = new DisplayClock();
            dc.Subscribe(clock);

            LogClock lc = new LogClock();
            lc.Subscribe(clock);

            clock.RunClock();

            Console.ReadLine();
        }

Comments

Post a Comment

Popular posts from this blog

C# Generic Factory

Implement Factory pattern using generics     public interface IDoWork   {       string DoWork();   }     Declare an Interface first by abstracting the common  functionality    Here I am taking the example of DoWork     public class Manager : IDoWork   {     public string DoWork()     {         return "Manager Manages School" ;     }   }     Implement the IDoWork in concrete classes as shown      public class Teacher : IDoWork     {         public string DoWork()         {             return "Teacher teaches student in school" ;         }     }     public class Student : IDoWork     {         public string DoWork()         {             return "Study in school" ;         }     } This class will actually create an instance of the concrete class so that you can work on that        object further     public class FactoryDemo     {         public T Create
7 comments
Read more

How to enable windows authentication in PostgreSQL

1.     Steps to create user or role in PostgreSQL ·         Open pgAdmin III ·         Login to PostgreSQL database ·         Select “Login Roles” and right click on mouse to view the context menu ·         Select “New Login Role” from context menu ·         Enter desired user name in “Role name” text box ·         Select “Definition” tab in “New Login Role” window ·         Enter desired Password in the given text box ·         Select “Role privileges” tab in “New Login Role” window ·         Select the privileges for the entered user or role ·         Select “SQL” tab in “New Login Role” window ·         This will display the auto generated script ·         Review the script and click on “OK” button ·         Now in the “Login Roles” the newly created role or user “newUser” is displayed ·         Now in pgAdmin III object browser select the database to which the newly created user should be ma
Post a Comment
Read more

UML - Association, Aggregation, Composition, Generalization, Specialization, Realization and Dependency

Association Association is a simple relationship between two classes. For example A relationship between Professor Class and Student class is known as Association. Both Classes can exist without each other, so Professor and Student are two independent classes. In this kind of relationships there will not be any owner class. Both classes have their own life cycle. UML Notation:     Aggregation Aggregation is a special type of Association. It is known as “Has-A” relationship. For example A Department class can contain Professor Class. Here Department class is owner class. Here in this relationship even after deleting Department class, Professor Class can exits. UML Notation: Composition Composition is a special type of Aggregation. It is known as “Is-A” relationship. For example A University Class has many Department class. Here University and Department objects are dependent on each other. If we delete University cl
1 comment
Read more