public interface ServiceInterface { 
	public String echo(String ping); 
	public int plus(int a, int b);
	public byte[] bin();
}

class MyService implements ServiceInterface {
	@Remote() 
	public String echo(String ping){ 
		return ping;
	}
	@Remote()
	public int plus(int a, int b) {
		return a + b;
	}

	@Remote
	public byte[] bin() {
		byte[] res = new byte[100];
		for (int i = 0; i < res.length; i++)
			res[i] = (byte) i;
		return res;
	}
}

public class RpcService {
public static void main(String[] args) throws InterruptedException { 
		WorkerPoolConfig cfg = new WorkerPoolConfig();
		cfg.setService("MyRpc"); 
		cfg.setBrokers(new String[] { "127.0.0.1:15555" });
		int threadCount = 2;
		WorkerPool wc = new WorkerPool(cfg);
		System.out.format("Pooled RPC(%d) Run...\n", threadCount);

		RpcServiceHandler handler = new RpcServiceHandler();  	
		handler.addModule("ServiceInterface", new MyService());  
		wc.run(threadCount, handler); 
	}
}

public class RpcFactoryExample {
public static void main(String[] args) throws Throwable { 
		
		ServiceInterface rpc = RpcFactory.getService(
				ServiceInterface.class, 
				"zbus://localhost:15555/MyRpc"); 
		
		String pong = rpc.echo("ping");
		
		System.out.println(pong); 
	}
}