stockimplementation.java

RMI asynchronism receive message callback() register and deregister to control update or interrupt

package server;

import java.rmi.RemoteException;
import java.util.ArrayList;
import java.util.Collection;



import both.CallBack;
import both.Stock;

public class StockImplementation implements Stock {
	Collection<CallBack> clients = new ArrayList<CallBack>() ;
	public void send(String symbol, int value) throws RemoteException {
		try{
			for(CallBack c : clients){
				c.callBack(symbol, value) ;
			}
			System.out.println("Symbol:"+symbol + "; Vaue:"+Integer.toString( value));
		}catch(Exception e){
			e.printStackTrace();}
	}

	public void register(CallBack c) throws RemoteException {
		System.out.println(c);
        clients.add(c);
	}
   
	public void interrupt(CallBack c) throws RemoteException {
		System.out.println(c);
		clients.remove(c);
	}
}