in src/main/java/com/microsoft/azure/functions/worker/handler/MessageHandler.java [38:60]
public void handle() {
StatusResult.Status status = StatusResult.Status.Success;
String statusMessage;
RpcException rpcException = null;
try {
this.response = this.responseSupplier.get();
statusMessage = this.execute(this.request, this.response);
if (statusMessage != null) {
this.getLogger().info(statusMessage);
}
} catch (Exception ex) {
status = StatusResult.Status.Failure;
statusMessage = ExceptionUtils.getRootCauseMessage(ex);
rpcException = RpcException.newBuilder().setMessage(statusMessage).setStackTrace(ExceptionUtils.getStackTrace(ex)).build();
}
if (this.responseStatusMarshaller != null) {
StatusResult.Builder result = StatusResult.newBuilder().setStatus(status).setResult(statusMessage);
if (rpcException != null) {
result = result.setException(rpcException);
}
this.responseStatusMarshaller.accept(this.response, result.build());
}
}