File tree Expand file tree Collapse file tree
fineract-core/src/main/java/org/apache/fineract/infrastructure Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2727@ Component
2828public class DataEnricherProcessor {
2929
30- private final List <DataEnricher <?> > enhancers ;
30+ private final List <DataEnricher > enhancers ;
3131
3232 @ Autowired
33- public DataEnricherProcessor (Optional <List <DataEnricher <?> >> enhancers ) {
34- this .enhancers = enhancers .orElse (new ArrayList <>());
33+ public DataEnricherProcessor (Optional <List <DataEnricher >> enhancers ) {
34+ this .enhancers = enhancers .orElse (new ArrayList <DataEnricher >());
3535 }
3636
3737 public <T > T enrich (T source ) {
Original file line number Diff line number Diff line change @@ -107,8 +107,15 @@ private List<ExternalEventResponse> convertToReadableFormat(List<ExternalEvent>
107107 var method = payLoadClass .getMethod ("fromByteBuffer" , ByteBuffer .class );
108108 var payLoad = method .invoke (null , byteBuffer );
109109 if (externalEvent .getType ().equalsIgnoreCase ("BulkBusinessEvent" )) {
110- var methodToGetDatas = payLoad .getClass ().getMethod ("getDatas" , (Class <?>) null );
111- var bulkMessages = (List <BulkMessageItemV1 >) methodToGetDatas .invoke (payLoad );
110+ var methodToGetDatas = payLoad .getClass ().getMethod ("getDatas" );
111+
112+ Object invokeResult = methodToGetDatas .invoke (payLoad );
113+ if (!(invokeResult instanceof List )) {
114+ throw new IllegalStateException ("Expected List from getDatas method" );
115+ }
116+
117+ List <BulkMessageItemV1 > bulkMessages = (List <BulkMessageItemV1 >) invokeResult ;
118+
112119 var bulkMessagePayload = new StringBuilder ();
113120 for (var bulkMessage : bulkMessages ) {
114121 var bulkMessageData = retrieveBulkMessage (bulkMessage , externalEvent );
You can’t perform that action at this time.
0 commit comments