IncAgent.java

package test;

import test.TopicManagerSingleton.TopicManager;

public class IncAgent implements Agent {
    private double value = 0;
    private String[] subs;
    private String[] pubs;
    private TopicManagerSingleton.TopicManager tm;

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

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

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

    @Override
    public void callback(String topic, Message msg) {
        // Update value based on input topic
        if (subs != null && subs.length > 0 && topic.equals(subs[0])) {
            value = msg.asDouble;
            value++;
            
            if (pubs != null && pubs.length > 0) {
                tm.getTopic(pubs[0]).publish(new Message(value));
            }
        }
    }

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