1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17 package org.openehealth.ipf.platform.camel.ihe.hl7v2.intercept.consumer;
18
19 import org.apache.camel.Exchange;
20 import org.openehealth.ipf.commons.ihe.core.Constants;
21 import org.openehealth.ipf.platform.camel.ihe.core.InterceptorSupport;
22 import org.openehealth.ipf.platform.camel.ihe.hl7v2.HL7v2Endpoint;
23
24
25
26
27 public class ConsumerRequestInteractionSetterInterceptor extends InterceptorSupport<HL7v2Endpoint> {
28
29 @Override
30 public void process(Exchange exchange) throws Exception {
31 exchange.getIn().setHeader(Constants.INTERACTION_ID_NAME, getEndpoint().getInteractionId());
32 getWrappedProcessor().process(exchange);
33 }
34 }