File RSBroadcast.java

File List > internal > message > RSBroadcast.java

Go to the documentation of this file

package skydata.internal.message;

import java.util.Set;

import skydata.internal.agents.SKAgent;

public class RSBroadcast implements BroadcastI{


    @SuppressWarnings("unused")
    public void broadcast(SKAgent sender, SKLMessage message, Set<SKAID> agents){
        message.clearReceivers();
        for (SKAID f : agents) {
            String sname = sender.getName();
            String rname = f.getName();
            if (!sname.equals(rname)){
                message.addReceiver(f);
            }
        }
        sender.skSendReliable(message);
    }
}