1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.openehealth.ipf.platform.camel.ihe.xds.iti41;
17
18 import org.openehealth.ipf.commons.ihe.ws.JaxWsClientFactory;
19 import org.openehealth.ipf.commons.ihe.ws.WsTransactionConfiguration;
20 import org.openehealth.ipf.commons.ihe.xds.core.audit.XdsSubmitAuditDataset;
21 import org.openehealth.ipf.commons.ihe.xds.core.ebxml.ebxml30.ProvideAndRegisterDocumentSetRequestType;
22 import org.openehealth.ipf.commons.ihe.xds.core.stub.ebrs30.rs.RegistryResponseType;
23 import org.openehealth.ipf.commons.ihe.xds.iti41.Iti41PortType;
24 import org.openehealth.ipf.platform.camel.ihe.ws.AbstractWsEndpoint;
25 import org.openehealth.ipf.platform.camel.ihe.xds.XdsSubmissionProducer;
26
27
28
29
30 public class Iti41Producer extends XdsSubmissionProducer<ProvideAndRegisterDocumentSetRequestType, RegistryResponseType> {
31
32 public Iti41Producer(AbstractWsEndpoint<XdsSubmitAuditDataset, WsTransactionConfiguration<XdsSubmitAuditDataset>> endpoint,
33 JaxWsClientFactory<XdsSubmitAuditDataset> clientFactory) {
34 super(endpoint, clientFactory, ProvideAndRegisterDocumentSetRequestType.class, RegistryResponseType.class);
35 }
36
37 @Override
38 protected RegistryResponseType callService(Object client, ProvideAndRegisterDocumentSetRequestType request) {
39 injectTargetHomeCommunityId(client, request.getSubmitObjectsRequest());
40 return ((Iti41PortType) client).documentRepositoryProvideAndRegisterDocumentSetB(request);
41 }
42
43 }