package com.dy.testServer.forRmi; 
 | 
  
 | 
import java.rmi.RemoteException; 
 | 
  
 | 
import com.dy.common.mw.channel.rmi.RmiRequestCallback; 
 | 
import org.apache.logging.log4j.LogManager; 
 | 
import org.apache.logging.log4j.Logger; 
 | 
  
 | 
public class RmiRequestedCallback implements RmiRequestCallback { 
 | 
  
 | 
    @SuppressWarnings("unused") 
 | 
    private static Logger log = LogManager.getLogger(RmiRequestedCallback.class.getName()) ; 
 | 
  
 | 
    @Override 
 | 
    public Object syncRequest(Object obj) throws RemoteException { 
 | 
        String json ; 
 | 
        try { 
 | 
            json = Manager.dealRequest(obj); 
 | 
        } catch (Exception e) { 
 | 
            throw new RemoteException("服务端异常" , e) ; 
 | 
        } 
 | 
        return json ; 
 | 
    } 
 | 
  
 | 
    @Override 
 | 
    public String asyncRequest(Object obj) throws RemoteException { 
 | 
        String json ; 
 | 
        try { 
 | 
            json = Manager.dealRequest(obj); 
 | 
        } catch (Exception e) { 
 | 
            throw new RemoteException("服务端异常" , e) ; 
 | 
        } 
 | 
        return json ; 
 | 
    } 
 | 
  
 | 
} 
 |