in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/EventTargetConverter.java [63:88]
public static EventTarget convertEventTarget(String accountId, String eventBusName,
String eventRuleName, EventTargetDTO eventTargetDTO) {
EventTarget eventTarget = EventTarget.builder()
.accountId(accountId)
.eventBusName(eventBusName)
.eventRuleName(eventRuleName)
.name(eventTargetDTO.getEventTargetName())
.className(eventTargetDTO.getClassName())
.config(eventTargetDTO.getConfig())
.build();
if (eventTargetDTO.getRunOptions() == null) {
return eventTarget;
}
RunOptions runOptions = RunOptions.builder()
.deadLetterQueue(convertDeadLetterQueue(eventTargetDTO.getRunOptions()
.getDeadLetterQueue()))
.errorsTolerance(convertErrorTolerance(eventTargetDTO.getRunOptions()
.getErrorsTolerance()))
.retryStrategy(convertRetryStrategy(eventTargetDTO.getRunOptions()
.getRetryStrategy()))
.build();
eventTarget.setRunOptions(runOptions);
return eventTarget;
}