package protocols.implementations; import java.util.ArrayList; import core.VSMessage; import prefs.VSPrefs; import protocols.VSProtocol; public class BroadcastSturmProtocol extends VSProtocol { private ArrayList sentMessages; private static int broadcastCount; public BroadcastSturmProtocol() { setClassname(getClass().toString()); sentMessages = new ArrayList(); } protected void onInit() { } protected void onClientReset() { } protected void onClientStart() { VSMessage message = new VSMessage(getClassname()); message.setInteger("Broadcast", broadcastCount++); sentMessages.add(message); sendMessage(message); } protected void onClientRecv(VSMessage recvMessage) { } protected void onServerReset() { sentMessages.clear(); } protected void onServerRecv(VSMessage recvMessage) { if (!sentMessages.contains(recvMessage)) { VSMessage message = new VSMessage(getClassname()); message.setInteger("Broadcast", recvMessage.getInteger("Broadcast")); sentMessages.add(message); sendMessage(message); } } public String toString() { return super.toString(); } }