Skip to content

Commit

Permalink
control-plane-adapter extension - adjustement to external changes
Browse files Browse the repository at this point in the history
  • Loading branch information
marcingajek-zf committed Nov 8, 2022
1 parent 0f938b0 commit 3e246c4
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
2 changes: 1 addition & 1 deletion edc-extensions/control-plane-adapter/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>net.catenax.edc.extensions</groupId>
<groupId>org.eclipse.tractusx.edc.extensions</groupId>
<artifactId>edc-extensions</artifactId>
<version>0.1.3-SNAPSHOT</version>
</parent>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,8 +24,8 @@
import net.catenax.edc.cp.adapter.process.contractnegotiation.ContractNegotiationHandler;
import net.catenax.edc.cp.adapter.process.contractnotification.ContractInMemorySyncService;
import net.catenax.edc.cp.adapter.process.contractnotification.ContractNotificationHandler;
import net.catenax.edc.cp.adapter.process.datareference.DataReferenceHandler;
import net.catenax.edc.cp.adapter.process.datareference.DataRefInMemorySyncService;
import net.catenax.edc.cp.adapter.process.datareference.DataReferenceHandler;
import net.catenax.edc.cp.adapter.service.ErrorResultService;
import net.catenax.edc.cp.adapter.service.ResultService;
import net.catenax.edc.cp.adapter.util.ExpiringMap;
Expand All @@ -35,13 +35,13 @@
import org.eclipse.dataspaceconnector.api.datamanagement.contractnegotiation.service.ContractNegotiationService;
import org.eclipse.dataspaceconnector.api.datamanagement.contractnegotiation.service.ContractNegotiationServiceImpl;
import org.eclipse.dataspaceconnector.api.datamanagement.transferprocess.service.TransferProcessService;
import org.eclipse.dataspaceconnector.runtime.metamodel.annotation.Inject;
import org.eclipse.dataspaceconnector.spi.WebService;
import org.eclipse.dataspaceconnector.spi.contract.negotiation.ConsumerContractNegotiationManager;
import org.eclipse.dataspaceconnector.spi.contract.negotiation.observe.ContractNegotiationObservable;
import org.eclipse.dataspaceconnector.spi.contract.negotiation.store.ContractNegotiationStore;
import org.eclipse.dataspaceconnector.spi.message.RemoteMessageDispatcherRegistry;
import org.eclipse.dataspaceconnector.spi.monitor.Monitor;
import org.eclipse.dataspaceconnector.spi.system.Inject;
import org.eclipse.dataspaceconnector.spi.system.ServiceExtension;
import org.eclipse.dataspaceconnector.spi.system.ServiceExtensionContext;
import org.eclipse.dataspaceconnector.spi.transaction.NoopTransactionContext;
Expand Down Expand Up @@ -133,8 +133,7 @@ private void initContractConfirmationHandler(
new ContractNotificationHandler(
monitor,
messageService,
new ContractInMemorySyncService(
new LockMap()),
new ContractInMemorySyncService(new LockMap()),
contractNegotiationService,
transferProcessService,
new InMemoryContractDataStore());
Expand All @@ -149,7 +148,8 @@ private void initDataReferenceHandler(
Monitor monitor, InMemoryMessageService messageService, ListenerService listenerService) {

DataReferenceHandler dataReferenceHandler =
new DataReferenceHandler(monitor, messageService, new DataRefInMemorySyncService(new LockMap()));
new DataReferenceHandler(
monitor, messageService, new DataRefInMemorySyncService(new LockMap()));
listenerService.addListener(Channel.DATA_REFERENCE, dataReferenceHandler);
receiverRegistry.registerReceiver(dataReferenceHandler);
}
Expand Down

0 comments on commit 3e246c4

Please sign in to comment.