<distributed-methods>
         <method-expression>void com.myOrg.myPkg.MyClass.anyMethod(Object,  Long)</method-expression>
        </distributed-methods>
 

 import java.net.*;
 import java.io.*;
 
 class TestServer extends Thread {
     public TestServer() {
         super("Demo");
         start();
     }
 
     public void run() {
         ServerSocket acceptSocket=null;
         try {
             acceptSocket = new ServerSocket(123);
             while(true) {
                 final Socket s = acceptSocket.accept();
                 Thread t = new Thread() {
                     public void run() {
                         try {
                             doRequest(s);
                         } catch(Exception err) {
                             System.out.println("Error at client :"+err);
                         }
                     }
                 };
                 t.start();
             }
         } catch (IOException e) {
             System.out.println("Error at server :"+e);
         } finally {
             try {
                 acceptSocket.close();
             }catch(Exception re){
                 throw new RuntimeException(re);
             }
         }
     }
 
     public final void doRequest(Socket s) throws IOException {
         InputStream in = s.getInputStream();
         OutputStream out=s.getOutputStream();
         PrintWriter rout=new PrintWriter(
         new BufferedOutputStream(out));
         rout.println("Hello");
         rout.flush();
         try {
             Thread.sleep(1000);
         } catch (InterruptedException e){
             System.out.println("Do request thread interrupted : "+e);
         } finally {
             out.close();
         }
         s.close();
     }
 
     public static void main(String args[]) {
         new TestServer();
     }
 }