package com.llgc.publisher;

public class Main {

  public static void main(String[] args) {
    Publisher publisher = new Publisher();

    Subscriber animalLover = new Subscriber();
    Subscriber oldCatLady = new Subscriber();

    PubSubServer server = new PubSubServer();

    Message dogMessage = new Message("Dogs", "Dogs are man's best friend");
    Message catMessage = new Message("Cats", "Cats can take care of themselves");

    // le publieur envoie un message qui sera conservé sur le serveur.
    publisher.send(dogMessage, server);
    publisher.send(catMessage, server);

    // On indique quels évènements chaque futur subscriber recevra.
    animalLover.listen("Dogs");
    animalLover.listen("Cats");

    oldCatLady.listen("Cats");

    // On enregistre les subscribers.
    server.addSubscriber(animalLover);
    server.addSubscriber(oldCatLady);
    
    // Le serveur fait suivre les messages en attente aux subscribers.
    server.forward();
    
    // On demande au subscriber de traiter les informations qu'il a reçu.
    System.out.println("animalLover has subcribed to the following messages :");
    animalLover.print();
    
    System.out.println("oldCatLady has subcribed to the following messages :");
    oldCatLady.print();
  }
}