| | |
| | | |
| | | while( reqHeaderEnum.hasMoreElements() ) { |
| | | String headerName = (String)reqHeaderEnum.nextElement(); |
| | | headers.put(headerName, request.getHeader(headerName)); |
| | | headers.put(headerName.toLowerCase(), request.getHeader(headerName)); |
| | | } |
| | | |
| | | headers.put("IP",getIpAddr(request)); |
| | | |
| | | headers.put("hostName",request.getLocalName()); |
| | | headers.put("port",request.getLocalPort()); |
| | | headers.put("port",request.getLocalPort()+""); |
| | | |
| | | } |
| | | |
| | |
| | | * @return |
| | | * @throws Exception |
| | | */ |
| | | protected BusinessServiceDataFlow writeDataToDataFlowContext(String reqJson, Map<String,String> headers) throws InitDataFlowContextException { |
| | | protected BusinessServiceDataFlow writeDataToDataFlowContext(String reqJson, Map<String,String> headers) throws Exception { |
| | | BusinessServiceDataFlow businessServiceDataFlow = DataFlowFactory.newInstance(BusinessServiceDataFlow.class).builder(reqJson,headers); |
| | | return businessServiceDataFlow; |
| | | } |