private TargetRunnerConfig buildTargetRunnerConfig()

in adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/runtime/RuntimeTargetRunnerAPIImpl.java [48:74]

26 lines of code
1 McCabe index (conditional complexity)


    private TargetRunnerConfig buildTargetRunnerConfig(String accountId, String name, Component source,
        Component target,
        String filterPattern, Map<String, TransformParam> targetTransform, RunOptions runOptions) {
        TargetRunnerConfig targetRunnerConfig = new TargetRunnerConfig();
        targetRunnerConfig.setName(name);
        List<Map<String, String>> components = Lists.newArrayList();
        targetRunnerConfig.setComponents(components);
        Map<String, String> sourceComponent = new Gson().fromJson(new Gson().toJson(source
            .getConfig()), new TypeToken<Map<String, String>>() {
        }.getType());
        Map<String, String> filterComponent = new Gson().fromJson(new Gson().toJson(RocketMQConverter.buildEventBridgeFilterTransform(filterPattern)
            .getConfig()), new TypeToken<Map<String, String>>() {
        }.getType());

        Map<String, String> transformComponent = new Gson().fromJson(new Gson().toJson(RocketMQConverter.buildEventBridgeTransform(targetTransform)
            .getConfig()), new TypeToken<Map<String, String>>() {
        }.getType());
        Map<String, String> targetComponent = new Gson().fromJson(new Gson().toJson(target
            .getConfig()), new TypeToken<Map<String, String>>() {
        }.getType());
        components.add(sourceComponent);
        components.add(filterComponent);
        components.add(transformComponent);
        components.add(targetComponent);
        targetRunnerConfig.setRunOptions(runOptions);
        return targetRunnerConfig;
    }