PlusAgent.java

package test;

public class PlusAgent implements Agent {
    private final String name;
    private final Topic input1;
    private final Topic input2;
    private final Topic output;

    private double x;
    private double y;

    public PlusAgent(String[] subs, String[] pubs) {
        if (subs == null || subs.length < 2) {
            throw new IllegalArgumentException("PlusAgent requires at least 2 subs");
        }
        if (pubs == null || pubs.length < 1) {
            throw new IllegalArgumentException("PlusAgent requires at least 1 pub");
        }
        this.name = "PlusAgent";
        TopicManagerSingleton.TopicManager tm = TopicManagerSingleton.get();
        this.input1 = tm.getTopic(subs[0].trim());
        this.input2 = tm.getTopic(subs[1].trim());
        this.output = tm.getTopic(pubs[0].trim());
        this.input1.subscribe(this);
        this.input2.subscribe(this);
        this.output.addPublisher(this);
        reset();
    }

    @Override
    public String getName() {
        return name;
    }

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

    @Override
    public void callback(String topic, Message msg) {
        if (msg == null) {
            return;
        }
        double val = msg.asDouble;
        if (Double.isNaN(val)) {
            return;
        }
        if (input1.name.equals(topic)) {
            x = val;
        } else if (input2.name.equals(topic)) {
            y = val;
        } else {
            return;
        }
        output.publish(new Message(x + y));
    }

    @Override
    public void close() {
    }
}