Reeks 5:

Publish/Subscribe

Newsbie applicatie

Siena pub/sub : subscribe

public class Subscriber implements Notifiable {

  ThinClient siena;
  public Subscriber() {
    siena = new ThinClient("ka:127.0.0.1:8080");
    Filter f = new Filter();
    // Add constraints
    siena.subscribe(f, this);
  }
  
  public void notify(Notification n) { }

  public void notify(Notification[] ns) { }

}
 

Siena pub/sub : publish

public class Publisher {

  ThinClient siena;

   public Publisher() {

     siena = new ThinClient("ka:127.0.0.1:8080");

  }

  public void publish(String message) {

    Notification n = new Notification();

    n.putAttribute("message", message);

    siena.publish(n);

  }
}