File tree Expand file tree Collapse file tree 1 file changed +8
-3
lines changed
springboot-starter/src/main/java/com/codingapi/springboot/framework/trigger Expand file tree Collapse file tree 1 file changed +8
-3
lines changed Original file line number Diff line number Diff line change 11package com .codingapi .springboot .framework .trigger ;
22
3+ import lombok .extern .slf4j .Slf4j ;
4+
35import java .lang .reflect .ParameterizedType ;
6+ import java .util .ArrayList ;
47import java .util .Iterator ;
58import java .util .List ;
69import java .util .Map ;
710import java .util .concurrent .ConcurrentHashMap ;
8- import java .util .concurrent .CopyOnWriteArrayList ;
911
1012
1113/**
1517 * Trigger是单独的消息数据不占用Event的通道。由于Event利用了Spring的事件底层,因此在大规模的事件情况下会堵塞spring的事件通道。
1618 */
1719@ SuppressWarnings ("all" )
20+ @ Slf4j
1821public class TriggerContext {
1922
2023 public static TriggerContext getInstance () {
@@ -38,7 +41,7 @@ public void addTrigger(TriggerHandler handler){
3841 Class <? extends Trigger > clazz = getTriggerClass (handler );
3942 List <TriggerHandler > triggerList = this .triggers .get (clazz );
4043 if (triggerList ==null ){
41- triggerList = new CopyOnWriteArrayList <>();
44+ triggerList = new ArrayList <>();
4245 this .triggers .put (clazz ,triggerList );
4346 }
4447 triggerList .add (handler );
@@ -74,7 +77,9 @@ public void trigger(Trigger trigger){
7477 iterator .remove ();
7578 }
7679 }
77- }catch (Exception e ){}
80+ }catch (Exception e ){
81+ log .warn ("trigger error:{}" ,e .getLocalizedMessage ());
82+ }
7883 }
7984 }
8085 }
You can’t perform that action at this time.
0 commit comments