1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.openehealth.ipf.platform.camel.ihe.hl7v3.iti47;
17
18 import org.apache.camel.Endpoint;
19 import org.openehealth.ipf.commons.ihe.hl7v3.audit.Hl7v3AuditDataset;
20 import org.openehealth.ipf.commons.ihe.hl7v3.Hl7v3ContinuationAwareWsTransactionConfiguration;
21 import org.openehealth.ipf.platform.camel.ihe.hl7v3.Hl7v3Component;
22 import org.openehealth.ipf.platform.camel.ihe.hl7v3.Hl7v3ContinuationAwareEndpoint;
23 import org.openehealth.ipf.platform.camel.ihe.ws.AbstractWebService;
24 import org.openehealth.ipf.platform.camel.ihe.ws.AbstractWsEndpoint;
25
26 import java.util.Map;
27
28 import static org.openehealth.ipf.commons.ihe.hl7v3.PDQV3.Interactions.ITI_47;
29
30
31
32
33 public class Iti47Component extends Hl7v3Component<Hl7v3ContinuationAwareWsTransactionConfiguration> {
34
35 public Iti47Component() {
36 super(ITI_47);
37 }
38
39 @Override
40 protected Endpoint createEndpoint(String uri, String remaining, Map<String, Object> parameters) {
41 return new Hl7v3ContinuationAwareEndpoint(uri, remaining, this, parameters) {
42
43 @Override
44 protected AbstractWebService getCustomServiceInstance(AbstractWsEndpoint<Hl7v3AuditDataset, Hl7v3ContinuationAwareWsTransactionConfiguration> endpoint) {
45 Hl7v3ContinuationAwareEndpoint endpoint2 = (Hl7v3ContinuationAwareEndpoint) endpoint;
46 return endpoint2.isSupportContinuation() ?
47 new Iti47ContinuationAwareService(endpoint2) :
48 new Iti47Service();
49 }
50
51 };
52 }
53
54 }