Skip to content
This repository was archived by the owner on Oct 6, 2025. It is now read-only.

Commit ca44b62

Browse files
hhundhhund
committed
Merge remote-tracking branch 'origin/issues/38_Upgrade_to_DSF_0.5.0'
into develop
2 parents 4a8a3d5 + 11c00ab commit ca44b62

148 files changed

Lines changed: 4007 additions & 1920 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎.gitignore‎

Lines changed: 12 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -26,18 +26,15 @@ codex-processes-ap1-test-data-generator/rsa/*.pem
2626
###
2727
# codex-processes-ap1-docker-test-setup ignores
2828
###
29-
codex-processes-ap1-docker-test-setup/**/bpe/app/conf/*.pem
30-
codex-processes-ap1-docker-test-setup/**/bpe/app/conf/*.p12
31-
codex-processes-ap1-docker-test-setup/**/bpe/app/log/*.log
32-
codex-processes-ap1-docker-test-setup/**/bpe/app/log/*.log.gz
33-
codex-processes-ap1-docker-test-setup/**/bpe/app/last_event/time.file
34-
codex-processes-ap1-docker-test-setup/**/bpe/app/plugin/*.jar
35-
codex-processes-ap1-docker-test-setup/**/bpe/app/process/*.jar
36-
codex-processes-ap1-docker-test-setup/**/bpe/proxy/ssl/*.pem
37-
38-
codex-processes-ap1-docker-test-setup/**/fhir/app/conf/*.p12
39-
codex-processes-ap1-docker-test-setup/**/fhir/app/log/*.log
40-
codex-processes-ap1-docker-test-setup/**/fhir/app/log/*.log.gz
41-
codex-processes-ap1-docker-test-setup/**/fhir/app/conf/bundle.xml
42-
codex-processes-ap1-docker-test-setup/**/fhir/app/conf/config.properties
43-
codex-processes-ap1-docker-test-setup/**/fhir/proxy/ssl/*.pem
29+
codex-processes-ap1-docker-test-setup/**/bpe/log/*.log
30+
codex-processes-ap1-docker-test-setup/**/bpe/log/*.log.gz
31+
codex-processes-ap1-docker-test-setup/**/bpe/last_event/time.file
32+
codex-processes-ap1-docker-test-setup/**/bpe/plugin/*.jar
33+
codex-processes-ap1-docker-test-setup/**/bpe/process/*.jar
34+
35+
codex-processes-ap1-docker-test-setup/**/fhir/conf/bundle.xml
36+
codex-processes-ap1-docker-test-setup/**/fhir/log/*.log
37+
codex-processes-ap1-docker-test-setup/**/fhir/log/*.log.gz
38+
39+
codex-processes-ap1-docker-test-setup/secrets/*.pem
40+
codex-processes-ap1-docker-test-setup/.env

‎codex-process-data-transfer/pom.xml‎

Lines changed: 35 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
<parent>
99
<groupId>de.netzwerk-universitaetsmedizin.codex</groupId>
1010
<artifactId>codex-processes-ap1</artifactId>
11-
<version>0.3.4-SNAPSHOT</version>
11+
<version>0.4.0-SNAPSHOT</version>
1212
</parent>
1313

1414
<properties>
@@ -59,7 +59,7 @@
5959
<version>${project.version}</version>
6060
</artifactItem>
6161
</artifactItems>
62-
<outputDirectory>../codex-processes-ap1-docker-test-setup/crr/bpe/app/process</outputDirectory>
62+
<outputDirectory>../codex-processes-ap1-docker-test-setup/crr/bpe/process</outputDirectory>
6363
</configuration>
6464
</execution>
6565
<execution>
@@ -76,7 +76,7 @@
7676
<version>${hapi.version}</version>
7777
</artifactItem>
7878
</artifactItems>
79-
<outputDirectory>../codex-processes-ap1-docker-test-setup/crr/bpe/app/plugin</outputDirectory>
79+
<outputDirectory>../codex-processes-ap1-docker-test-setup/crr/bpe/plugin</outputDirectory>
8080
</configuration>
8181
</execution>
8282
<execution>
@@ -93,7 +93,7 @@
9393
<version>${project.version}</version>
9494
</artifactItem>
9595
</artifactItems>
96-
<outputDirectory>../codex-processes-ap1-docker-test-setup/dic/bpe/app/process</outputDirectory>
96+
<outputDirectory>../codex-processes-ap1-docker-test-setup/dic/bpe/process</outputDirectory>
9797
</configuration>
9898
</execution>
9999
<execution>
@@ -110,7 +110,7 @@
110110
<version>${hapi.version}</version>
111111
</artifactItem>
112112
</artifactItems>
113-
<outputDirectory>../codex-processes-ap1-docker-test-setup/dic/bpe/app/plugin</outputDirectory>
113+
<outputDirectory>../codex-processes-ap1-docker-test-setup/dic/bpe/plugin</outputDirectory>
114114
</configuration>
115115
</execution>
116116
<execution>
@@ -127,7 +127,24 @@
127127
<version>${project.version}</version>
128128
</artifactItem>
129129
</artifactItems>
130-
<outputDirectory>../codex-processes-ap1-docker-test-setup/gth/bpe/app/process</outputDirectory>
130+
<outputDirectory>../codex-processes-ap1-docker-test-setup/gth/bpe/process</outputDirectory>
131+
</configuration>
132+
</execution>
133+
<execution>
134+
<id>copy-hapi-fhir-client/gth</id>
135+
<phase>package</phase>
136+
<goals>
137+
<goal>copy</goal>
138+
</goals>
139+
<configuration>
140+
<artifactItems>
141+
<artifactItem>
142+
<groupId>ca.uhn.hapi.fhir</groupId>
143+
<artifactId>hapi-fhir-client</artifactId>
144+
<version>${hapi.version}</version>
145+
</artifactItem>
146+
</artifactItems>
147+
<outputDirectory>../codex-processes-ap1-docker-test-setup/gth/bpe/plugin</outputDirectory>
131148
</configuration>
132149
</execution>
133150
</executions>
@@ -138,40 +155,47 @@
138155
<configuration>
139156
<filesets>
140157
<fileset>
141-
<directory>../codex-processes-ap1-docker-test-setup/crr/bpe/app/process</directory>
158+
<directory>../codex-processes-ap1-docker-test-setup/crr/bpe/process</directory>
142159
<includes>
143160
<include>${project.artifactId}-${project.version}.jar</include>
144161
</includes>
145162
<followSymlinks>false</followSymlinks>
146163
</fileset>
147164
<fileset>
148-
<directory>../codex-processes-ap1-docker-test-setup/crr/bpe/app/plugin</directory>
165+
<directory>../codex-processes-ap1-docker-test-setup/crr/bpe/plugin</directory>
149166
<includes>
150167
<include>hapi-fhir-client-${hapi.version}.jar</include>
151168
</includes>
152169
<followSymlinks>false</followSymlinks>
153170
</fileset>
154171
<fileset>
155-
<directory>../codex-processes-ap1-docker-test-setup/dic/bpe/app/process</directory>
172+
<directory>../codex-processes-ap1-docker-test-setup/dic/bpe/process</directory>
156173
<includes>
157174
<include>${project.artifactId}-${project.version}.jar</include>
158175
</includes>
159176
<followSymlinks>false</followSymlinks>
160177
</fileset>
161178
<fileset>
162-
<directory>../codex-processes-ap1-docker-test-setup/dic/bpe/app/plugin</directory>
179+
<directory>../codex-processes-ap1-docker-test-setup/dic/bpe/plugin</directory>
163180
<includes>
164181
<include>hapi-fhir-client-${hapi.version}.jar</include>
165182
</includes>
166183
<followSymlinks>false</followSymlinks>
167184
</fileset>
168185
<fileset>
169-
<directory>../codex-processes-ap1-docker-test-setup/gth/bpe/app/process</directory>
186+
<directory>../codex-processes-ap1-docker-test-setup/gth/bpe/process</directory>
170187
<includes>
171188
<include>${project.artifactId}-${project.version}.jar</include>
172189
</includes>
173190
<followSymlinks>false</followSymlinks>
174191
</fileset>
192+
<fileset>
193+
<directory>../codex-processes-ap1-docker-test-setup/gth/bpe/plugin</directory>
194+
<includes>
195+
<include>hapi-fhir-client-${hapi.version}.jar</include>
196+
</includes>
197+
<followSymlinks>false</followSymlinks>
198+
</fileset>
175199
</filesets>
176200
</configuration>
177201
</plugin>

‎codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/ConstantsDataTransfer.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -32,26 +32,26 @@ public interface ConstantsDataTransfer
3232

3333
String PROFILE_NUM_CODEX_TASK_START_DATA_TRIGGER = "http://www.netzwerk-universitaetsmedizin.de/fhir/StructureDefinition/task-start-data-trigger";
3434
String PROFILE_NUM_CODEX_TASK_STOP_DATA_TRIGGER = "http://www.netzwerk-universitaetsmedizin.de/fhir/StructureDefinition/task-stop-data-trigger";
35-
String PROFILE_NUM_CODEX_TASK_DATA_TRIGGER_PROCESS_URI = "http://highmed.org/bpe/Process/dataTrigger/";
35+
String PROFILE_NUM_CODEX_TASK_DATA_TRIGGER_PROCESS_URI = "http://www.netzwerk-universitaetsmedizin.de/bpe/Process/dataTrigger/";
3636
String PROFILE_NUM_CODEX_TASK_DATA_TRIGGER_PROCESS_URI_AND_LATEST_VERSION = PROFILE_NUM_CODEX_TASK_DATA_TRIGGER_PROCESS_URI
3737
+ VERSION;
3838
String PROFILE_NUM_CODEX_TASK_START_DATA_TRIGGER_MESSAGE_NAME = "startDataTrigger";
3939
String PROFILE_NUM_CODEX_TASK_STOP_DATA_TRIGGER_MESSAGE_NAME = "stopDataTrigger";
4040

4141
String PROFILE_NUM_CODEX_TASK_START_DATA_SEND = "http://www.netzwerk-universitaetsmedizin.de/fhir/StructureDefinition/task-start-data-send";
42-
String PROFILE_NUM_CODEX_TASK_DATA_SEND_PROCESS_URI = "http://highmed.org/bpe/Process/dataSend/";
42+
String PROFILE_NUM_CODEX_TASK_DATA_SEND_PROCESS_URI = "http://www.netzwerk-universitaetsmedizin.de/bpe/Process/dataSend/";
4343
String PROFILE_NUM_CODEX_TASK_DATA_SEND_PROCESS_URI_AND_LATEST_VERSION = PROFILE_NUM_CODEX_TASK_DATA_SEND_PROCESS_URI
4444
+ VERSION;
4545
String PROFILE_NUM_CODEX_TASK_START_DATA_SEND_MESSAGE_NAME = "startDataSend";
4646

4747
String PROFILE_NUM_CODEX_TASK_START_DATA_TRANSLATE = "http://www.netzwerk-universitaetsmedizin.de/fhir/StructureDefinition/task-start-data-translate";
48-
String PROFILE_NUM_CODEX_TASK_DATA_TRANSLATE_PROCESS_URI = "http://highmed.org/bpe/Process/dataTranslate/";
48+
String PROFILE_NUM_CODEX_TASK_DATA_TRANSLATE_PROCESS_URI = "http://www.netzwerk-universitaetsmedizin.de/bpe/Process/dataTranslate/";
4949
String PROFILE_NUM_CODEX_TASK_DATA_TRANSLATE_PROCESS_URI_AND_LATEST_VERSION = PROFILE_NUM_CODEX_TASK_DATA_TRANSLATE_PROCESS_URI
5050
+ VERSION;
5151
String PROFILE_NUM_CODEX_TASK_START_DATA_TRANSLATE_MESSAGE_NAME = "startDataTranslate";
5252

5353
String PROFILE_NUM_CODEX_TASK_START_DATA_RECEIVE = "http://www.netzwerk-universitaetsmedizin.de/fhir/StructureDefinition/task-start-data-receive";
54-
String PROFILE_NUM_CODEX_TASK_DATA_RECEIVE_PROCESS_URI = "http://highmed.org/bpe/Process/dataReceive/";
54+
String PROFILE_NUM_CODEX_TASK_DATA_RECEIVE_PROCESS_URI = "http://www.netzwerk-universitaetsmedizin.de/bpe/Process/dataReceive/";
5555
String PROFILE_NUM_CODEX_TASK_DATA_RECEIVE_PROCESS_URI_AND_LATEST_VERSION = PROFILE_NUM_CODEX_TASK_DATA_RECEIVE_PROCESS_URI
5656
+ VERSION;
5757
String PROFILE_NUM_CODEX_TASK_START_DATA_RECEIVE_MESSAGE_NAME = "startDataReceive";

‎codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/DataTransferProcessPluginDefinition.java‎

Lines changed: 13 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -13,14 +13,15 @@
1313
import org.highmed.dsf.fhir.resources.ResourceProvider;
1414
import org.highmed.dsf.fhir.resources.StructureDefinitionResource;
1515
import org.highmed.dsf.fhir.resources.ValueSetResource;
16+
import org.springframework.core.env.PropertyResolver;
1617

1718
import ca.uhn.fhir.context.FhirContext;
1819
import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.spring.config.TransferDataConfig;
1920
import de.netzwerk_universitaetsmedizin.codex.processes.data_transfer.spring.config.TransferDataSerializerConfig;
2021

2122
public class DataTransferProcessPluginDefinition implements ProcessPluginDefinition
2223
{
23-
public static final String VERSION = "0.3.4";
24+
public static final String VERSION = "0.4.0";
2425

2526
@Override
2627
public String getName()
@@ -47,7 +48,8 @@ public Stream<Class<?>> getSpringConfigClasses()
4748
}
4849

4950
@Override
50-
public ResourceProvider getResourceProvider(FhirContext fhirContext, ClassLoader classLoader)
51+
public ResourceProvider getResourceProvider(FhirContext fhirContext, ClassLoader classLoader,
52+
PropertyResolver propertyResolver)
5153
{
5254
var aTri = ActivityDefinitionResource.file("fhir/ActivityDefinition/num-codex-data-trigger.xml");
5355
var aSen = ActivityDefinitionResource.file("fhir/ActivityDefinition/num-codex-data-send.xml");
@@ -73,12 +75,16 @@ public ResourceProvider getResourceProvider(FhirContext fhirContext, ClassLoader
7375
var vD = ValueSetResource.file("fhir/ValueSet/num-codex-data-transfer.xml");
7476

7577
Map<String, List<AbstractResource>> resourcesByProcessKeyAndVersion = Map.of( //
76-
"dataTrigger/" + VERSION, Arrays.asList(aTri, cD, nD, sTstaDtri, sTstoDtri, vD), //
77-
"dataSend/" + VERSION, Arrays.asList(aSen, cD, nD, nB, sTstaDsen, vD), //
78-
"dataTranslate/" + VERSION, Arrays.asList(aTra, cD, nD, nC, sTstaDtra, vD), //
79-
"dataReceive/" + VERSION, Arrays.asList(aRec, cD, nC, sTstaDrec, vD));
78+
"wwwnetzwerk-universitaetsmedizinde_dataTrigger/" + VERSION,
79+
Arrays.asList(aTri, cD, nD, sTstaDtri, sTstoDtri, vD), //
80+
"wwwnetzwerk-universitaetsmedizinde_dataSend/" + VERSION,
81+
Arrays.asList(aSen, cD, nD, nB, sTstaDsen, vD), //
82+
"wwwnetzwerk-universitaetsmedizinde_dataTranslate/" + VERSION,
83+
Arrays.asList(aTra, cD, nD, nC, sTstaDtra, vD), //
84+
"wwwnetzwerk-universitaetsmedizinde_dataReceive/" + VERSION,
85+
Arrays.asList(aRec, cD, nC, sTstaDrec, vD));
8086

8187
return ResourceProvider.read(VERSION, () -> fhirContext.newXmlParser().setStripVersionsFromReferences(false),
82-
classLoader, resourcesByProcessKeyAndVersion);
88+
classLoader, propertyResolver, resourcesByProcessKeyAndVersion);
8389
}
8490
}

‎codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/client/FttpClientFactory.java‎

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -9,17 +9,17 @@
99
import java.security.KeyStoreException;
1010
import java.security.MessageDigest;
1111
import java.security.NoSuchAlgorithmException;
12+
import java.security.PrivateKey;
1213
import java.security.cert.Certificate;
1314
import java.security.cert.CertificateException;
1415
import java.security.cert.X509Certificate;
15-
import java.security.interfaces.RSAPrivateCrtKey;
16-
import java.security.spec.InvalidKeySpecException;
1716
import java.util.Optional;
1817
import java.util.UUID;
1918
import java.util.regex.Matcher;
2019
import java.util.regex.Pattern;
2120

2221
import org.apache.commons.codec.binary.Hex;
22+
import org.bouncycastle.pkcs.PKCSException;
2323
import org.slf4j.Logger;
2424
import org.slf4j.LoggerFactory;
2525
import org.springframework.context.event.ContextRefreshedEvent;
@@ -189,14 +189,13 @@ private KeyStore readKeyStore(Path certificatePath, Path keyPath, char[] keyStor
189189
{
190190
try
191191
{
192-
RSAPrivateCrtKey privateKey = PemIo.readPrivateKeyFromPem(keyPath);
192+
PrivateKey privateKey = PemIo.readPrivateKeyFromPem(keyPath);
193193
X509Certificate certificate = PemIo.readX509CertificateFromPem(certificatePath);
194194

195195
return CertificateHelper.toJksKeyStore(privateKey, new Certificate[] { certificate },
196196
UUID.randomUUID().toString(), keyStorePassword);
197197
}
198-
catch (NoSuchAlgorithmException | InvalidKeySpecException | CertificateException | KeyStoreException
199-
| IOException e)
198+
catch (NoSuchAlgorithmException | CertificateException | KeyStoreException | IOException | PKCSException e)
200199
{
201200
throw new RuntimeException(e);
202201
}

‎codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/client/fhir/AbstractFhirClient.java‎

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -115,6 +115,8 @@ public AbstractFhirClient(FhirContext fhirContext, HapiFhirClientFactory clientF
115115
public PatientReferenceList getPatientReferencesWithNewData(DateWithPrecision exportFrom, Date exportTo)
116116
{
117117
Bundle searchBundle = getSearchBundle(exportFrom, exportTo);
118+
BundleType expectedResponseType = BundleType.BATCH.equals(searchBundle.getType()) ? BundleType.BATCHRESPONSE
119+
: BundleType.TRANSACTIONRESPONSE;
118120

119121
if (logger.isDebugEnabled())
120122
logger.debug("Executing Search-Bundle: {}",
@@ -126,6 +128,29 @@ public PatientReferenceList getPatientReferencesWithNewData(DateWithPrecision ex
126128
if (logger.isDebugEnabled())
127129
logger.debug("Search-Bundle result: {}", fhirContext.newJsonParser().encodeResourceToString(resultBundle));
128130

131+
if (!resultBundle.hasType() || !expectedResponseType.equals(resultBundle.getType()) || !resultBundle.hasEntry())
132+
{
133+
logger.warn("Search-Bundle result not a {} or has no entries", expectedResponseType.toCode());
134+
throw new RuntimeException(
135+
"Search-Bundle result not a " + expectedResponseType.toCode() + " or has no entries");
136+
}
137+
138+
for (int i = 0; i < resultBundle.getEntry().size(); i++)
139+
{
140+
BundleEntryComponent entry = resultBundle.getEntry().get(i);
141+
142+
if (!entry.hasResource() || !(entry.getResource() instanceof Bundle) || !entry.hasResponse()
143+
|| !entry.getResponse().hasStatus() || !entry.getResponse().getStatus().startsWith("200"))
144+
{
145+
logger.warn(
146+
"Error in Search-Bundle at index {}: entry has no Bundle resource or response is not 200 OK",
147+
i);
148+
if (entry.hasResource() && !(entry.getResource() instanceof Bundle))
149+
logger.debug("Unexpected entry resource: {}",
150+
fhirContext.newJsonParser().encodeResourceToString(entry.getResource()));
151+
}
152+
}
153+
129154
Stream<Patient> patients = resultBundle.getEntry().stream()
130155
.filter(e -> e.hasResource() && e.getResource() instanceof Bundle).map(e -> (Bundle) e.getResource())
131156
.flatMap(this::getPatients);

‎codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/crypto/CrrKeyProviderImpl.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,10 +7,10 @@
77
import java.security.NoSuchAlgorithmException;
88
import java.security.PrivateKey;
99
import java.security.PublicKey;
10-
import java.security.interfaces.RSAPrivateCrtKey;
1110
import java.security.interfaces.RSAPublicKey;
1211
import java.security.spec.InvalidKeySpecException;
1312

13+
import org.bouncycastle.pkcs.PKCSException;
1414
import org.slf4j.Logger;
1515
import org.slf4j.LoggerFactory;
1616

@@ -42,7 +42,7 @@ public static CrrKeyProviderImpl fromFiles(String crrPrivateKeyFile, String crrP
4242
+ crrPublicKeyFile + ") set");
4343
}
4444

45-
RSAPrivateCrtKey crrPrivateKey = null;
45+
PrivateKey crrPrivateKey = null;
4646
RSAPublicKey crrPublicKey = null;
4747
try
4848
{
@@ -56,7 +56,7 @@ public static CrrKeyProviderImpl fromFiles(String crrPrivateKeyFile, String crrP
5656
}
5757

5858
}
59-
catch (NoSuchAlgorithmException | InvalidKeySpecException | IOException e)
59+
catch (IOException | PKCSException e)
6060
{
6161
throw new RuntimeException("Error while reading CRR private-key from " + crrPrivateKeyFile, e);
6262
}

‎codex-process-data-transfer/src/main/java/de/netzwerk_universitaetsmedizin/codex/processes/data_transfer/message/StartReceiveProcess.java‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -11,10 +11,12 @@
1111
import java.util.stream.Stream;
1212

1313
import org.camunda.bpm.engine.delegate.DelegateExecution;
14+
import org.highmed.dsf.fhir.authorization.read.ReadAccessHelper;
1415
import org.highmed.dsf.fhir.client.FhirWebserviceClientProvider;
1516
import org.highmed.dsf.fhir.organization.OrganizationProvider;
1617
import org.highmed.dsf.fhir.task.AbstractTaskMessageSend;
1718
import org.highmed.dsf.fhir.task.TaskHelper;
19+
import org.highmed.dsf.fhir.variables.Target;
1820
import org.hl7.fhir.r4.model.Identifier;
1921
import org.hl7.fhir.r4.model.Reference;
2022
import org.hl7.fhir.r4.model.Task.ParameterComponent;
@@ -29,9 +31,9 @@ public class StartReceiveProcess extends AbstractTaskMessageSend
2931
private static final Logger logger = LoggerFactory.getLogger(StartReceiveProcess.class);
3032

3133
public StartReceiveProcess(FhirWebserviceClientProvider clientProvider, TaskHelper taskHelper,
32-
OrganizationProvider organizationProvider, FhirContext fhirContext)
34+
ReadAccessHelper readAccessHelper, OrganizationProvider organizationProvider, FhirContext fhirContext)
3335
{
34-
super(clientProvider, taskHelper, organizationProvider, fhirContext);
36+
super(clientProvider, taskHelper, readAccessHelper, organizationProvider, fhirContext);
3537
}
3638

3739
@Override
@@ -41,16 +43,14 @@ protected Stream<ParameterComponent> getAdditionalInputParameters(DelegateExecut
4143
}
4244

4345
@Override
44-
protected void sendTask(String targetOrganizationIdentifierValue, String processDefinitionKey, String versionTag,
45-
String messageName, String businessKey, String correlationKey, String profile,
46-
Stream<ParameterComponent> additionalInputParameters)
46+
protected void sendTask(Target target, String instantiatesUri, String messageName, String businessKey,
47+
String profile, Stream<ParameterComponent> additionalInputParameters)
4748
{
4849
String crrBusinessKey = UUID.randomUUID().toString();
4950

5051
logger.info("DIC businessKey {}, CRR businessKey {}", businessKey, crrBusinessKey);
5152

52-
super.sendTask(targetOrganizationIdentifierValue, processDefinitionKey, versionTag, messageName, crrBusinessKey,
53-
correlationKey, profile, additionalInputParameters);
53+
super.sendTask(target, instantiatesUri, messageName, crrBusinessKey, profile, additionalInputParameters);
5454
}
5555

5656
private ParameterComponent pseudonymParameter(DelegateExecution execution)

0 commit comments

Comments
 (0)