1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.openehealth.ipf.platform.camel.ihe.xds.dispatch;
17
18 import org.apache.cxf.interceptor.Fault;
19 import org.apache.cxf.message.Message;
20 import org.openehealth.ipf.commons.ihe.ws.cxf.payload.InPayloadExtractorInterceptor;
21 import org.openehealth.ipf.commons.ihe.ws.cxf.payload.StringPayloadHolder;
22
23 import javax.xml.namespace.QName;
24 import java.util.HashSet;
25 import java.util.Set;
26
27
28
29
30 public class DispatchInPayloadExtractorInterceptor extends InPayloadExtractorInterceptor {
31 private final static Set<QName> SET = new HashSet<>();
32 static {
33 SET.add(new QName("urn:ihe:iti:xds-b:2007", "DocumentRegistry_RegistryStoredQuery"));
34 SET.add(new QName("urn:ihe:iti:xds-b:2007", "RespondingGateway_CrossGatewayQuery"));
35 SET.add(new QName("urn:ihe:iti:xds-b:2007", "DocumentRegistry_MultiPatientStoredQuery"));
36 SET.add(new QName("urn:ihe:iti:xds-b:2007", "RespondingGateway_CrossGatewayFetch"));
37 }
38
39
40 public DispatchInPayloadExtractorInterceptor() {
41 super(StringPayloadHolder.PayloadType.SOAP_BODY);
42 }
43
44 @Override
45 public void handleMessage(Message message) throws Fault {
46
47
48
49
50
51
52
53
54
55
56
57
58
59 super.handleMessage(message);
60 }
61 }