in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/classes/EventTargetClassService.java [52:72]
public EventTargetClass checkEventSourceAPIParams(String name, Map<String, Object> inputConfig) {
EventTargetClass eventTargetClass = this.getClassByName(name);
for (Map.Entry<String, APIAttribute> entry : eventTargetClass.getApiParams()
.entrySet()) {
if (!inputConfig.containsKey(entry.getKey()) && entry.getValue()
.isRequired() && entry.getValue()
.getDefaultValue() == null) {
throw new EventBridgeException(EventTargetMissingAttribute, entry.getKey(), entry.getValue()
.getDescription());
}
}
for (Map.Entry<String, Object> entry : inputConfig.entrySet()) {
if (!eventTargetClass.getApiParams()
.containsKey(entry.getKey())) {
throw new EventBridgeException(EventTargetIneffectiveAttribute, entry.getKey(), String.join(",",
eventTargetClass.getApiParams()
.keySet()));
}
}
return eventTargetClass;
}