diff --git a/transfer/transfer-04-event-consumer/listener/src/main/java/org/eclipse/edc/sample/extension/listener/TransferProcessStartedListener.java b/transfer/transfer-04-event-consumer/listener/src/main/java/org/eclipse/edc/sample/extension/listener/TransferProcessStartedListener.java index d9c33c74..35ebc4d2 100644 --- a/transfer/transfer-04-event-consumer/listener/src/main/java/org/eclipse/edc/sample/extension/listener/TransferProcessStartedListener.java +++ b/transfer/transfer-04-event-consumer/listener/src/main/java/org/eclipse/edc/sample/extension/listener/TransferProcessStartedListener.java @@ -15,6 +15,7 @@ package org.eclipse.edc.sample.extension.listener; import org.eclipse.edc.connector.controlplane.transfer.spi.observe.TransferProcessListener; +import org.eclipse.edc.connector.controlplane.transfer.spi.observe.TransferProcessStartedData; import org.eclipse.edc.connector.controlplane.transfer.spi.types.TransferProcess; import org.eclipse.edc.spi.monitor.Monitor; @@ -27,13 +28,14 @@ public TransferProcessStartedListener(Monitor monitor) { } /** - * Callback invoked by the EDC framework when a transfer is about to be completed. + * Callback invoked by the EDC framework when a transfer is started. * - * @param process the transfer process that is about to be completed. + * @param process the transfer process that has been started. + * @param additionalData additional data associated with the started transfer process. */ @Override - public void preStarted(final TransferProcess process) { + public void started(final TransferProcess process, final TransferProcessStartedData additionalData) { monitor.info("TransferProcessStartedListener received STARTED event"); - // do something meaningful before transfer start + // do something meaningful when transfer starts } }