Topic.java

package test;
import java.util.ArrayList;
import java.util.List;
import java.util.Collections;

public class Topic {
    public final String name;
    private final List<Agent> subs; // מאזינים
    private final List<Agent> pubs; // מפרסמים
    
    // public בנאי
    public Topic(String name) {
        this.name = name;
        this.subs = new ArrayList<>();
        this.pubs = new ArrayList<>();
    }
    
    public void subscribe(Agent agent) {
        if (!subs.contains(agent)) {
            subs.add(agent);
        }
    }
    
    public void unsubscribe(Agent agent) {
        subs.remove(agent);
    }
    
    public void publish(Message msg) {
        // שליחת ההודעה לכל המאזינים
        for (Agent agent : subs) {
            agent.callback(name, msg);
        }
    }
    
    public void addPublisher(Agent agent) {
        if (!pubs.contains(agent)) {
            pubs.add(agent);
        }
    }
    
    public void removePublisher(Agent agent) {
        pubs.remove(agent);
    }

    // Add this method to return an unmodifiable list of subscribers
    public List<Agent> getSubs() {
        return Collections.unmodifiableList(subs);
    }
    
    // Add this method to return an unmodifiable list of publishers
    public List<Agent> getPubs() {
        return Collections.unmodifiableList(pubs);
    }
}