refactor: remove dataplaneId from DataFlowResponseMessage (#5652)

ndr-brt · web-flow · commit 9bcce99c9ae3 · 2026-04-13T11:03:55.000+02:00
* refactor: remove dataplaneId from DataFlowResponseMessage

* rename message
diff --git a/data-protocols/data-plane-signaling/data-plane-signaling-core/src/main/java/org/eclipse/edc/signaling/DataPlaneSignalingApiExtension.java b/data-protocols/data-plane-signaling/data-plane-signaling-core/src/main/java/org/eclipse/edc/signaling/DataPlaneSignalingApiExtension.java
@@ -23,7 +23,7 @@
 import org.eclipse.edc.signaling.port.api.DataPlaneTransferApiController;
 import org.eclipse.edc.signaling.port.api.DataPlaneTransferAuthorizationFilter;
 import org.eclipse.edc.signaling.port.transformer.DataAddressToDspDataAddressTransformer;
-import org.eclipse.edc.signaling.port.transformer.DataFlowResponseMessageToDataFlowResponseTransformer;
+import org.eclipse.edc.signaling.port.transformer.DataFlowStatusMessageToDataFlowResponseTransformer;
 import org.eclipse.edc.signaling.port.transformer.DspDataAddressToDataAddressTransformer;
 import org.eclipse.edc.signaling.spi.authorization.SignalingAuthorizationRegistry;
 import org.eclipse.edc.spi.system.ServiceExtension;
@@ -76,7 +76,7 @@ public void initialize(ServiceExtensionContext context) {
 
         var typeTransformerRegistry = transformerRegistry.forContext("signaling-api");
         typeTransformerRegistry.register(new DataAddressToDspDataAddressTransformer());
-        typeTransformerRegistry.register(new DataFlowResponseMessageToDataFlowResponseTransformer());
+        typeTransformerRegistry.register(new DataFlowStatusMessageToDataFlowResponseTransformer());
         typeTransformerRegistry.register(new DspDataAddressToDataAddressTransformer());
 
         webService.registerResource(ApiContext.MANAGEMENT, new DataPlaneRegistrationApiV4Controller(dataPlaneSelectorService));
diff --git a/data-protocols/data-plane-signaling/data-plane-signaling-core/src/main/java/org/eclipse/edc/signaling/DataPlaneSignalingFlowControllerExtension.java b/data-protocols/data-plane-signaling/data-plane-signaling-core/src/main/java/org/eclipse/edc/signaling/DataPlaneSignalingFlowControllerExtension.java
@@ -24,7 +24,7 @@
 import org.eclipse.edc.signaling.logic.DataPlaneSignalingFlowController;
 import org.eclipse.edc.signaling.port.ClientFactory;
 import org.eclipse.edc.signaling.port.transformer.DataAddressToDspDataAddressTransformer;
-import org.eclipse.edc.signaling.port.transformer.DataFlowResponseMessageToDataFlowResponseTransformer;
+import org.eclipse.edc.signaling.port.transformer.DataFlowStatusMessageToDataFlowResponseTransformer;
 import org.eclipse.edc.signaling.port.transformer.DspDataAddressToDataAddressTransformer;
 import org.eclipse.edc.spi.system.ServiceExtension;
 import org.eclipse.edc.transform.spi.TypeTransformerRegistry;
@@ -58,7 +58,7 @@ public String name() {
     public DataFlowController dataFlowController() {
         var typeTransformerRegistry = transformerRegistry.forContext("signaling-api");
         typeTransformerRegistry.register(new DataAddressToDspDataAddressTransformer());
-        typeTransformerRegistry.register(new DataFlowResponseMessageToDataFlowResponseTransformer());
+        typeTransformerRegistry.register(new DataFlowStatusMessageToDataFlowResponseTransformer());
         typeTransformerRegistry.register(new DspDataAddressToDataAddressTransformer());
         return new DataPlaneSignalingFlowController(apiConfiguration.createPublicUri(), dataPlaneSelectorService,
                 typeTransformerRegistry, clientFactory, dataAddressStore);
diff --git a/data-protocols/data-plane-signaling/data-plane-signaling-core/src/main/java/org/eclipse/edc/signaling/domain/DataFlowStatusMessage.java b/data-protocols/data-plane-signaling/data-plane-signaling-core/src/main/java/org/eclipse/edc/signaling/domain/DataFlowStatusMessage.java
@@ -14,21 +14,16 @@
 
 package org.eclipse.edc.signaling.domain;
 
-public final class DataFlowResponseMessage {
+public final class DataFlowStatusMessage {
 
-    private String dataplaneId;
     private DspDataAddress dataAddress;
     private String state;
     private String error;
 
-    private DataFlowResponseMessage() {
+    private DataFlowStatusMessage() {
 
     }
 
-    public String getDataplaneId() {
-        return dataplaneId;
-    }
-
     public DspDataAddress getDataAddress() {
         return dataAddress;
     }
@@ -43,7 +38,7 @@ public String getError() {
 
     public static class Builder {
 
-        private final DataFlowResponseMessage instance = new DataFlowResponseMessage();
+        private final DataFlowStatusMessage instance = new DataFlowStatusMessage();
 
         public static Builder newInstance() {
             return new Builder();
@@ -53,16 +48,11 @@ private Builder() {
 
         }
 
-        public DataFlowResponseMessage build() {
+        public DataFlowStatusMessage build() {
             return instance;
         }
 
 
-        public Builder dataplaneId(String dataplaneId) {
-            instance.dataplaneId = dataplaneId;
-            return this;
-        }
-
         public Builder dataAddress(DspDataAddress dataAddress) {
             instance.dataAddress = dataAddress;
             return this;
diff --git a/data-protocols/data-plane-signaling/data-plane-signaling-core/src/main/java/org/eclipse/edc/signaling/logic/DataPlaneSignalingFlowController.java b/data-protocols/data-plane-signaling/data-plane-signaling-core/src/main/java/org/eclipse/edc/signaling/logic/DataPlaneSignalingFlowController.java
@@ -95,9 +95,11 @@ public StatusResult<DataFlowResponse> prepare(TransferProcess transferProcess, P
 
         var message = builder.build();
 
-        return clientFactory.createClient(selection.getContent())
+        var dataPlaneInstance = selection.getContent();
+        return clientFactory.createClient(dataPlaneInstance)
                 .prepare(message)
                 .compose(response -> typeTransformerRegistry.transform(response, DataFlowResponse.class)
+                        .<DataFlowResponse, Result<DataFlowResponse>>map(r -> r.toBuilder().dataPlaneId(dataPlaneInstance.getId()).build())
                         .flatMap(this::toStatusResult));
     }
 
@@ -137,9 +139,11 @@ public StatusResult<DataFlowResponse> prepare(TransferProcess transferProcess, P
 
         var message = builder.build();
 
-        return clientFactory.createClient(selection.getContent())
+        var dataPlaneInstance = selection.getContent();
+        return clientFactory.createClient(dataPlaneInstance)
                 .start(message)
                 .compose(response -> typeTransformerRegistry.transform(response, DataFlowResponse.class)
+                        .<DataFlowResponse, Result<DataFlowResponse>>map(r -> r.toBuilder().dataPlaneId(dataPlaneInstance.getId()).build())
                         .flatMap(this::toStatusResult));
     }
 
diff --git a/data-protocols/data-plane-signaling/data-plane-signaling-core/src/main/java/org/eclipse/edc/signaling/port/DataPlaneSignalingClient.java b/data-protocols/data-plane-signaling/data-plane-signaling-core/src/main/java/org/eclipse/edc/signaling/port/DataPlaneSignalingClient.java
@@ -23,9 +23,9 @@
 import org.eclipse.edc.connector.dataplane.selector.spi.instance.DataPlaneInstance;
 import org.eclipse.edc.http.spi.EdcHttpClient;
 import org.eclipse.edc.signaling.domain.DataFlowPrepareMessage;
-import org.eclipse.edc.signaling.domain.DataFlowResponseMessage;
 import org.eclipse.edc.signaling.domain.DataFlowStartMessage;
 import org.eclipse.edc.signaling.domain.DataFlowStartedNotificationMessage;
+import org.eclipse.edc.signaling.domain.DataFlowStatusMessage;
 import org.eclipse.edc.signaling.spi.authorization.SignalingAuthorizationRegistry;
 import org.eclipse.edc.spi.response.StatusResult;
 import org.eclipse.edc.spi.result.Result;
@@ -60,13 +60,13 @@ public DataPlaneSignalingClient(DataPlaneInstance dataPlane, EdcHttpClient httpC
         this.authorizationRegistry = authorizationRegistry;
     }
 
-    public StatusResult<DataFlowResponseMessage> prepare(DataFlowPrepareMessage request) {
+    public StatusResult<DataFlowStatusMessage> prepare(DataFlowPrepareMessage request) {
         var url = "%s/prepare".formatted(dataPlane.getUrl());
         return createRequestBuilder(request, url)
                 .compose(builder -> execute(builder, this::handleResponse));
     }
 
-    public StatusResult<DataFlowResponseMessage> start(DataFlowStartMessage request) {
+    public StatusResult<DataFlowStatusMessage> start(DataFlowStartMessage request) {
         var url = "%s/start".formatted(dataPlane.getUrl());
         return createRequestBuilder(request, url)
                 .compose(builder -> execute(builder, this::handleResponse));
@@ -103,14 +103,14 @@ private StatusResult<Void> sendMessage(String flowId, String name, Object messag
         }
     }
 
-    private Result<DataFlowResponseMessage> handleResponse(Response response) {
+    private Result<DataFlowStatusMessage> handleResponse(Response response) {
         if (!response.isSuccessful()) {
             return Result.failure("Data-plane responded with %d - %s".formatted(response.code(), response.message()));
         }
 
         try {
             var inputStream = response.body().byteStream();
-            var message = objectMapperSupplier.get().readValue(inputStream, DataFlowResponseMessage.class);
+            var message = objectMapperSupplier.get().readValue(inputStream, DataFlowStatusMessage.class);
             return Result.success(message);
         } catch (IOException e) {
             return Result.failure("Cannot parse response body: " + e.getMessage());
diff --git a/data-protocols/data-plane-signaling/data-plane-signaling-core/src/main/java/org/eclipse/edc/signaling/port/api/DataPlaneTransferApi.java b/data-protocols/data-plane-signaling/data-plane-signaling-core/src/main/java/org/eclipse/edc/signaling/port/api/DataPlaneTransferApi.java
@@ -23,7 +23,7 @@
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.ws.rs.core.Response;
 import org.eclipse.edc.api.model.ApiCoreSchema;
-import org.eclipse.edc.signaling.domain.DataFlowResponseMessage;
+import org.eclipse.edc.signaling.domain.DataFlowStatusMessage;
 
 import static jakarta.ws.rs.HttpMethod.POST;
 
@@ -40,7 +40,7 @@ public interface DataPlaneTransferApi {
                             content = @Content(array = @ArraySchema(schema = @Schema(implementation = ApiCoreSchema.ApiErrorDetailSchema.class))))
             }
     )
-    Response prepared(String transferId, DataFlowResponseMessage message);
+    Response prepared(String transferId, DataFlowStatusMessage message);
 
     @Operation(
             method = POST,
@@ -51,7 +51,7 @@ public interface DataPlaneTransferApi {
                             content = @Content(array = @ArraySchema(schema = @Schema(implementation = ApiCoreSchema.ApiErrorDetailSchema.class))))
             }
     )
-    Response started(String transferId, DataFlowResponseMessage message);
+    Response started(String transferId, DataFlowStatusMessage message);
 
     @Operation(
             method = POST,
diff --git a/data-protocols/data-plane-signaling/data-plane-signaling-core/src/main/java/org/eclipse/edc/signaling/port/api/DataPlaneTransferApiController.java b/data-protocols/data-plane-signaling/data-plane-signaling-core/src/main/java/org/eclipse/edc/signaling/port/api/DataPlaneTransferApiController.java
@@ -26,8 +26,8 @@
 import org.eclipse.edc.connector.controlplane.transfer.spi.types.command.NotifyPreparedCommand;
 import org.eclipse.edc.connector.controlplane.transfer.spi.types.command.NotifyStartedCommand;
 import org.eclipse.edc.signaling.domain.DataFlowPrepareMessage;
-import org.eclipse.edc.signaling.domain.DataFlowResponseMessage;
 import org.eclipse.edc.signaling.domain.DataFlowStartMessage;
+import org.eclipse.edc.signaling.domain.DataFlowStatusMessage;
 import org.eclipse.edc.spi.result.ServiceResult;
 import org.eclipse.edc.transform.spi.TypeTransformerRegistry;
 
@@ -51,7 +51,7 @@ public DataPlaneTransferApiController(TransferProcessService transferProcessServ
     @Path("/{transferId}/dataflow/prepared")
     @POST
     @Override
-    public Response prepared(@PathParam("transferId") String transferId, DataFlowResponseMessage message) {
+    public Response prepared(@PathParam("transferId") String transferId, DataFlowStatusMessage message) {
         typeTransformerRegistry.transform(message, DataFlowResponse.class)
                 .map(ServiceResult::success)
                 .orElse(failure -> ServiceResult.badRequest(failure.getMessages()))
@@ -65,7 +65,7 @@ public Response prepared(@PathParam("transferId") String transferId, DataFlowRes
     @Path("/{transferId}/dataflow/started")
     @POST
     @Override
-    public Response started(@PathParam("transferId") String transferId, DataFlowResponseMessage message) {
+    public Response started(@PathParam("transferId") String transferId, DataFlowStatusMessage message) {
         typeTransformerRegistry.transform(message, DataFlowResponse.class)
                 .map(ServiceResult::success)
                 .orElse(failure -> ServiceResult.badRequest(failure.getMessages()))
diff --git a/data-protocols/data-plane-signaling/data-plane-signaling-core/src/main/java/org/eclipse/edc/signaling/port/transformer/DataFlowStatusMessageToDataFlowResponseTransformer.java b/data-protocols/data-plane-signaling/data-plane-signaling-core/src/main/java/org/eclipse/edc/signaling/port/transformer/DataFlowStatusMessageToDataFlowResponseTransformer.java
@@ -15,18 +15,18 @@
 package org.eclipse.edc.signaling.port.transformer;
 
 import org.eclipse.edc.connector.controlplane.transfer.spi.types.DataFlowResponse;
-import org.eclipse.edc.signaling.domain.DataFlowResponseMessage;
+import org.eclipse.edc.signaling.domain.DataFlowStatusMessage;
 import org.eclipse.edc.spi.types.domain.DataAddress;
 import org.eclipse.edc.transform.spi.TransformerContext;
 import org.eclipse.edc.transform.spi.TypeTransformer;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 
-public class DataFlowResponseMessageToDataFlowResponseTransformer implements TypeTransformer<DataFlowResponseMessage, DataFlowResponse> {
+public class DataFlowStatusMessageToDataFlowResponseTransformer implements TypeTransformer<DataFlowStatusMessage, DataFlowResponse> {
 
     @Override
-    public Class<DataFlowResponseMessage> getInputType() {
-        return DataFlowResponseMessage.class;
+    public Class<DataFlowStatusMessage> getInputType() {
+        return DataFlowStatusMessage.class;
     }
 
     @Override
@@ -35,11 +35,10 @@ public Class<DataFlowResponse> getOutputType() {
     }
 
     @Override
-    public @Nullable DataFlowResponse transform(@NotNull DataFlowResponseMessage dataFlowResponseMessage, @NotNull TransformerContext context) {
+    public @Nullable DataFlowResponse transform(@NotNull DataFlowStatusMessage dataFlowStatusMessage, @NotNull TransformerContext context) {
         return DataFlowResponse.Builder.newInstance()
-                .dataAddress(context.transform(dataFlowResponseMessage.getDataAddress(), DataAddress.class))
-                .dataPlaneId(dataFlowResponseMessage.getDataplaneId())
-                .async(dataFlowResponseMessage.getState().endsWith("ING"))
+                .dataAddress(context.transform(dataFlowStatusMessage.getDataAddress(), DataAddress.class))
+                .async(dataFlowStatusMessage.getState().endsWith("ING"))
                 .build();
     }
 
diff --git a/data-protocols/data-plane-signaling/data-plane-signaling-core/src/test/java/org/eclipse/edc/signaling/logic/DataPlaneSignalingFlowControllerTest.java b/data-protocols/data-plane-signaling/data-plane-signaling-core/src/test/java/org/eclipse/edc/signaling/logic/DataPlaneSignalingFlowControllerTest.java
@@ -22,8 +22,8 @@
 import org.eclipse.edc.connector.dataplane.selector.spi.instance.DataPlaneInstance;
 import org.eclipse.edc.policy.model.Policy;
 import org.eclipse.edc.signaling.domain.DataFlowPrepareMessage;
-import org.eclipse.edc.signaling.domain.DataFlowResponseMessage;
 import org.eclipse.edc.signaling.domain.DataFlowStartMessage;
+import org.eclipse.edc.signaling.domain.DataFlowStatusMessage;
 import org.eclipse.edc.signaling.domain.DspDataAddress;
 import org.eclipse.edc.signaling.port.ClientFactory;
 import org.eclipse.edc.signaling.port.DataPlaneSignalingClient;
@@ -74,22 +74,24 @@ class Prepare {
 
         @Test
         void shouldCallPrepareOnDataPlane() {
-            var dataPlaneInstance = createDataPlaneInstance();
+            var dataPlaneInstance = dataPlaneInstanceBuilder().id("data-plane-id").build();
             Map<String, Object> claims = Map.of("key", "value");
             var transferProcess = transferProcessBuilder().claims(claims).build();
             when(selectorService.selectFor(any())).thenReturn(ServiceResult.success(dataPlaneInstance));
             when(clientFactory.createClient(any())).thenReturn(dataPlaneClient);
-            var flowResponseMessage = DataFlowResponseMessage.Builder.newInstance()
+            var flowResponseMessage = DataFlowStatusMessage.Builder.newInstance()
                     .dataAddress(createDspDataAddress())
                     .build();
             when(dataPlaneClient.prepare(any())).thenReturn(StatusResult.success(flowResponseMessage));
             when(typeTransformerRegistry.transform(isA(DataAddress.class), any())).thenReturn(Result.success(createDspDataAddress()));
-            var response = DataFlowResponse.Builder.newInstance().dataPlaneId("dataPlaneId").dataAddress(testDataAddress()).build();
-            when(typeTransformerRegistry.transform(isA(DataFlowResponseMessage.class), any())).thenReturn(Result.success(response));
+            var response = DataFlowResponse.Builder.newInstance().dataAddress(testDataAddress()).build();
+            when(typeTransformerRegistry.transform(isA(DataFlowStatusMessage.class), any())).thenReturn(Result.success(response));
 
             var result = flowController.prepare(transferProcess, policyBuilder().build());
 
-            assertThat(result).isSucceeded().isSameAs(response);
+            assertThat(result).isSucceeded().satisfies(actualResponse -> {
+                assertThat(actualResponse.getDataPlaneId()).isEqualTo("data-plane-id");
+            });
             var captor = ArgumentCaptor.forClass(DataFlowPrepareMessage.class);
             verify(dataPlaneClient).prepare(captor.capture());
             var message = captor.getValue();
@@ -120,20 +122,22 @@ void shouldSelectAndCallStartOnDataplane() {
                     .transferType(HTTP_DATA_PULL)
                     .contentDataAddress(testDataAddress())
                     .build();
-            var dataPlaneInstance = createDataPlaneInstance();
+            var dataPlaneInstance = dataPlaneInstanceBuilder().id("data-plane-id").build();
             when(selectorService.selectFor(any())).thenReturn(ServiceResult.success(dataPlaneInstance));
             when(clientFactory.createClient(any())).thenReturn(dataPlaneClient);
             when(typeTransformerRegistry.transform(isA(DataAddress.class), any())).thenReturn(Result.success(createDspDataAddress()));
             var response = DataFlowResponse.Builder.newInstance().dataPlaneId("dataPlaneId").dataAddress(testDataAddress()).build();
-            when(typeTransformerRegistry.transform(isA(DataFlowResponseMessage.class), any())).thenReturn(Result.success(response));
-            when(dataPlaneClient.start(any())).thenReturn(StatusResult.success(DataFlowResponseMessage.Builder.newInstance()
+            when(typeTransformerRegistry.transform(isA(DataFlowStatusMessage.class), any())).thenReturn(Result.success(response));
+            when(dataPlaneClient.start(any())).thenReturn(StatusResult.success(DataFlowStatusMessage.Builder.newInstance()
                     .dataAddress(createDspDataAddress())
                     .build()));
             when(dataAddressStore.resolve(any())).thenReturn(StoreResult.success(DataAddress.Builder.newInstance().type("test").build()));
 
             var result = flowController.start(transferProcess, policy);
 
-            assertThat(result).isSucceeded().isSameAs(response);
+            assertThat(result).isSucceeded().satisfies(actualResponse -> {
+                assertThat(actualResponse.getDataPlaneId()).isEqualTo("data-plane-id");
+            });
             var captor = ArgumentCaptor.forClass(DataFlowStartMessage.class);
             verify(dataPlaneClient).start(captor.capture());
             var message = captor.getValue();
@@ -163,7 +167,7 @@ void returnFailedResultIfTransferFails() {
                     .build();
 
             when(dataPlaneClient.start(any())).thenReturn(StatusResult.failure(ResponseStatus.FATAL_ERROR, errorMsg));
-            var dataPlaneInstance = createDataPlaneInstance();
+            var dataPlaneInstance = dataPlaneInstanceBuilder().build();
             when(selectorService.selectFor(any())).thenReturn(ServiceResult.success(dataPlaneInstance));
             when(clientFactory.createClient(any())).thenReturn(dataPlaneClient);
             when(typeTransformerRegistry.transform(isA(DataAddress.class), any())).thenReturn(Result.success(createDspDataAddress()));
@@ -426,10 +430,6 @@ private DataPlaneInstance.Builder dataPlaneInstanceBuilder() {
         return DataPlaneInstance.Builder.newInstance().url("http://any");
     }
 
-    private DataPlaneInstance createDataPlaneInstance() {
-        return dataPlaneInstanceBuilder().build();
-    }
-
     private DataAddress testDataAddress() {
         return DataAddress.Builder.newInstance().type("test-type").build();
     }
diff --git a/data-protocols/data-plane-signaling/data-plane-signaling-core/src/test/java/org/eclipse/edc/signaling/port/api/DataPlaneTransferApiControllerTest.java b/data-protocols/data-plane-signaling/data-plane-signaling-core/src/test/java/org/eclipse/edc/signaling/port/api/DataPlaneTransferApiControllerTest.java
diff --git a/data-protocols/data-plane-signaling/data-plane-signaling-core/src/test/java/org/eclipse/edc/signaling/port/transformer/DataFlowStatusMessageToDataFlowResponseTransformerTest.java b/data-protocols/data-plane-signaling/data-plane-signaling-core/src/test/java/org/eclipse/edc/signaling/port/transformer/DataFlowStatusMessageToDataFlowResponseTransformerTest.java
diff --git a/data-protocols/data-plane-signaling/src/main/resources/signaling-api-version.json b/data-protocols/data-plane-signaling/src/main/resources/signaling-api-version.json
diff --git a/spi/control-plane/transfer-spi/src/main/java/org/eclipse/edc/connector/controlplane/transfer/spi/types/DataFlowResponse.java b/spi/control-plane/transfer-spi/src/main/java/org/eclipse/edc/connector/controlplane/transfer/spi/types/DataFlowResponse.java

Original file line number	Diff line number	Diff line change
`@@ -23,7 +23,7 @@`
`23`	`23`	`import io.swagger.v3.oas.annotations.tags.Tag;`
`24`	`24`	`import jakarta.ws.rs.core.Response;`
`25`	`25`	`import org.eclipse.edc.api.model.ApiCoreSchema;`
`26`		`-import org.eclipse.edc.signaling.domain.DataFlowResponseMessage;`
	`26`	`+import org.eclipse.edc.signaling.domain.DataFlowStatusMessage;`
`27`	`27`
`28`	`28`	`import static jakarta.ws.rs.HttpMethod.POST;`
`29`	`29`
`@@ -40,7 +40,7 @@ public interface DataPlaneTransferApi {`
`40`	`40`	`content = @Content(array = @ArraySchema(schema = @Schema(implementation = ApiCoreSchema.ApiErrorDetailSchema.class))))`
`41`	`41`	`}`
`42`	`42`	`)`
`43`		`- Response prepared(String transferId, DataFlowResponseMessage message);`
	`43`	`+ Response prepared(String transferId, DataFlowStatusMessage message);`
`44`	`44`
`45`	`45`	`@Operation(`
`46`	`46`	`method = POST,`
`@@ -51,7 +51,7 @@ public interface DataPlaneTransferApi {`
`51`	`51`	`content = @Content(array = @ArraySchema(schema = @Schema(implementation = ApiCoreSchema.ApiErrorDetailSchema.class))))`
`52`	`52`	`}`
`53`	`53`	`)`
`54`		`- Response started(String transferId, DataFlowResponseMessage message);`
	`54`	`+ Response started(String transferId, DataFlowStatusMessage message);`
`55`	`55`
`56`	`56`	`@Operation(`
`57`	`57`	`method = POST,`