New file |
| | |
| | | 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 ; |
| | | } |
| | | |
| | | } |