- public abstract void setQueryRequest(Exchange exchange) ;
-
- public abstract void setQueryResponse(Exchange exchange);
-
- protected String getTxId(final Exchange exchange){
- String txId = exchange.getIn().getHeader("X-TransactionId",String.class);
- return ((txId==null||txId.isEmpty())?UUID.randomUUID().toString():txId);
- }
-
- protected boolean checkRecursion(String url){
- return url.contains(DATA_ROUTER_PORT);
- }
-
- protected void setMDC(final Exchange exchange) {
- String transId = exchange.getIn().getHeader(HEADER_TRANS_ID, String.class);
- String appId = exchange.getIn().getHeader(HEADER_FROM_APP_ID, String.class);
- String hostId = exchange.getIn().getHeader(HEADER_FROM_HOST, String.class);
+ /** HTTP header containing the calling host details */
+ static final String DATA_ROUTER_PORT = "9502";