1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.openehealth.ipf.platform.camel.ihe.xds;
17
18 import org.slf4j.Logger;
19 import org.slf4j.LoggerFactory;
20 import org.apache.cxf.message.Exchange;
21 import org.openehealth.ipf.commons.ihe.ws.cxf.AbstractWsRejectionHandlingStrategy;
22
23 import java.util.concurrent.atomic.AtomicInteger;
24
25
26
27
28
29 public class MyRejectionHandlingStrategy extends AbstractWsRejectionHandlingStrategy {
30 private static final Logger LOG = LoggerFactory.getLogger(MyRejectionHandlingStrategy.class);
31
32 private static final AtomicInteger COUNTER = new AtomicInteger(0);
33
34 public static void resetCounter() {
35 COUNTER.set(0);
36 }
37
38 public static int getCount() {
39 return COUNTER.get();
40 }
41
42 @Override
43 public void handleRejectedExchange(Exchange cxfExchange) {
44 COUNTER.getAndIncrement();
45 }
46 }