PlusAgent.java

package test;

import test.TopicManagerSingleton.TopicManager;

public class PlusAgent implements Agent {
    private double x = 0;
    private double y = 0;
    private String[] subs;
    private String[] pubs;
    private TopicManagerSingleton.TopicManager tm;

    public PlusAgent(String[] subs, String[] pubs) {
        this.subs = subs;
        this.pubs = pubs;
        
        // Get TopicManager instance
        this.tm = TopicManagerSingleton.get();
        
        // Subscribe to input topics
        if (subs != null && subs.length >= 2) {
            tm.getTopic(subs[0]).subscribe(this);
            tm.getTopic(subs[1]).subscribe(this);
        }
    }

    @Override
    public String getName() {
        return "PlusAgent";
    }

    @Override
    public void reset() {
        x = 0;
        y = 0;
    }

    @Override
    public void callback(String topic, Message msg) {
        // Update x or y based on the input topic
        if (subs != null && subs.length >= 2) {
            if (topic.equals(subs[0])) {
                x = msg.asDouble;
            } else if (topic.equals(subs[1])) {
                y = msg.asDouble;
            }

            // If both x and y are valid, calculate and publish
            if (pubs != null && pubs.length > 0) {
                double result = x + y;
                tm.getTopic(pubs[0]).publish(new Message(result));
            }
        }
    }

    @Override
    public void close() {
        // Unsubscribe from topics if needed
        if (subs != null && subs.length >= 2) {
            tm.getTopic(subs[0]).unsubscribe(this);
            tm.getTopic(subs[1]).unsubscribe(this);
        }
    }
}