1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.openehealth.ipf.platform.camel.ihe.hl7v3.iti55.asyncresponse;
17
18 import org.apache.camel.ExchangePattern;
19 import org.openehealth.ipf.commons.ihe.hl7v3.Hl7v3Utils;
20 import org.openehealth.ipf.commons.ihe.hl7v3.iti55.Iti55Utils;
21 import org.openehealth.ipf.commons.ihe.hl7v3.iti55.asyncresponse.Iti55AsyncResponsePortType;
22 import org.openehealth.ipf.platform.camel.ihe.ws.AbstractAsyncResponseWebService;
23
24
25
26
27
28
29 public class Iti55AsyncResponseService extends AbstractAsyncResponseWebService implements Iti55AsyncResponsePortType {
30
31 @Override
32 public void receiveAsyncResponse(String responseString) {
33 process(responseString, null, ExchangePattern.InOnly);
34 }
35
36 @Override
37 protected String[] getAlternativeResponseKeys(Object response) {
38 return new String[] { Iti55Utils.responseQueryId(Hl7v3Utils.slurp((String) response)) };
39 }
40 }