调试服务器上无法分发消息问题

This commit is contained in:
zhouxiunai
2018-12-10 18:17:50 +08:00
parent e90eec3e3d
commit e17f615ede
@@ -21,12 +21,12 @@ public class MsgHandlerDispatcher {
public HandlerResult dispatch(Cminmsg cminmsg) public HandlerResult dispatch(Cminmsg cminmsg)
{ {
MSG msg = exchangeService.xmlstrToObject(cminmsg.getCminmsgsClobMsg(), MSG.class);
String type = msg.getMETA().getTYPE().name();
String subType = msg.getMETA().getSTYP().name();
try try
{ {
MSG msg = exchangeService.xmlstrToObject(cminmsg.getCminmsgsClobMsg(), MSG.class);
String type = msg.getMETA().getTYPE().name();
String subType = msg.getMETA().getSTYP().name();
Class clazzHandler = Class.forName(getHandlerClassName(type,subType)); Class clazzHandler = Class.forName(getHandlerClassName(type,subType));
Object classObject = clazzHandler.newInstance(); Object classObject = clazzHandler.newInstance();
Method runMethod = clazzHandler.getMethod("run", Cminmsg.class); Method runMethod = clazzHandler.getMethod("run", Cminmsg.class);