gistfile1.txt

    //Inside publisher
    
    @Override
    public void setInActive(Reason reason) {
        super.setInActive(reason);
        notifier.streamCreated(super.getSession(), super.getConnection(), this);
        for (PublisherListener pl : this.getListeners()) {
            pl.publisherDestroyed(this);
        }
    }
    
    @Override
    public void setActive(Reason reason) {
        notifier.streamCreated(super.getSession(), super.getConnection(), this);
        for (PublisherListener pl : this.getListeners()) {
            pl.publisherModified(this, "active");
        }
    }
    
    //Inside Session
    addPublisher(publisher) {
       publisher.addListener(this);
    }
    
    publisherModified(publisher, property) {
        if property == active
            getPublisherListeners().publisherCreated(publisher)
    }
  
  @JsonIgnore
    //PublisherListener
    public interface PublisherListener {
          void publisherModified(....)
          void publisherDestroyed(....)
    }
    
    public interface NewPublisherListener {
          void publisherCreated(....)
    }