| | |
|---|
| | | import com.java110.utils.util.Assert; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | |
|---|
| | | import java.text.ParseException; |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.List; |
|---|
| | |
|---|
| | | * @param event |
|---|
| | | * @param asyn A 表示异步处理 |
|---|
| | | */ |
|---|
| | | public static void multicastEvent(String serviceCode, final CmdEvent event, String asyn) { |
|---|
| | | public static void multicastEvent(String serviceCode, final CmdEvent event, String asyn) throws ParseException { |
|---|
| | | List<ServiceCmdListener> listeners = getListeners(serviceCode); |
|---|
| | | //这里判断 serviceCode + httpMethod 的侦听，如果没有注册直接报错。 |
|---|
| | | if (listeners == null || listeners.size() == 0) { |
|---|
| | |
|---|
| | | executor.execute(new Runnable() { |
|---|
| | | @Override |
|---|
| | | public void run() { |
|---|
| | | invokeListener(listener, event); |
|---|
| | | try { |
|---|
| | | invokeListener(listener, event); |
|---|
| | | } catch (ParseException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | break; |
|---|
| | |
|---|
| | | * @since 4.1 |
|---|
| | | */ |
|---|
| | | @SuppressWarnings({"unchecked", "rawtypes"}) |
|---|
| | | protected static void invokeListener(ServiceCmdListener listener, CmdEvent event) { |
|---|
| | | protected static void invokeListener(ServiceCmdListener listener, CmdEvent event) throws ParseException { |
|---|
| | | try { |
|---|
| | | // //这里处理业务逻辑数据 |
|---|
| | | ICmdDataFlowContext dataFlowContext = event.getCmdDataFlowContext(); |
|---|
| | |
|---|
| | | |
|---|
| | | //logger.debug("API服务 --- 返回报文信息：{}", dataFlowContext.getResponseEntity()); |
|---|
| | | // listener.cmd(event); |
|---|
| | | } catch (CmdException e) { |
|---|
| | | } catch (CmdException | ParseException e) { |
|---|
| | | LoggerEngine.error("发布侦听失败", e); |
|---|
| | | throw e; |
|---|
| | | } |
|---|
