打印 Observable 对象
Print Observable object
如何打印JaxRS编程的Observable,调试第三方响应
RollOutCalculatorClientImpl.debugLogger.debug("{}", ()->"--------------->Hitting Account Details SAPI with URL :"
+ webTarget.getUri().toString());
Return Type = Observable < Map < String, Object >>
final RxWebTarget < RxObservableInvoker > webTarget = this.rxClient.target(
this.endpointResolver.getServiceEndpoint(userRequestContext, Constants.SAPI_ROLL_OUT_CALCULATOR_ENDPOINT))
.resolveTemplates(requestParamValues);
RollOutCalculatorClientImpl.debugLogger.debug("{}", ()->"--------------->Hitting Account Details SAPI with URL :"
+ webTarget.getUri().toString());
userRequestContext.getTracker().stopRequestTime();
Observable < Response > reponse = webTarget.request().headers(userRequestContext.getHeaders()).rx().get().single();
returnreponse.map(sapiResponse->{
Map < String,
Object > respo = ResponseParser.parse(sapiResponse, userRequestContext);
System.out.println("Sumeet----->" + respo);
returnrespo;
});
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.ObjectWriter;
ObjectWriter ow = new ObjectMapper().writer().withDefaultPrettyPrinter();
String json = ow.writeValueAsString(object);
如何打印JaxRS编程的Observable,调试第三方响应
RollOutCalculatorClientImpl.debugLogger.debug("{}", ()->"--------------->Hitting Account Details SAPI with URL :"
+ webTarget.getUri().toString());
Return Type = Observable < Map < String, Object >>
final RxWebTarget < RxObservableInvoker > webTarget = this.rxClient.target(
this.endpointResolver.getServiceEndpoint(userRequestContext, Constants.SAPI_ROLL_OUT_CALCULATOR_ENDPOINT))
.resolveTemplates(requestParamValues);
RollOutCalculatorClientImpl.debugLogger.debug("{}", ()->"--------------->Hitting Account Details SAPI with URL :"
+ webTarget.getUri().toString());
userRequestContext.getTracker().stopRequestTime();
Observable < Response > reponse = webTarget.request().headers(userRequestContext.getHeaders()).rx().get().single();
returnreponse.map(sapiResponse->{
Map < String,
Object > respo = ResponseParser.parse(sapiResponse, userRequestContext);
System.out.println("Sumeet----->" + respo);
returnrespo;
});
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.ObjectWriter;
ObjectWriter ow = new ObjectMapper().writer().withDefaultPrettyPrinter();
String json = ow.writeValueAsString(object);