Как обработать исключение тайм-аута в quarkus?

Я пытаюсь подключиться к стороннему API из контроллера quarkus. У меня есть контроллер, использующий метод обслуживания. Блок try catch не работает. У меня есть все необходимые зависимости, и я следил за документом quarkus Вот код

Контроллер

package com.ncr.invoice;

// all imports over here 

@Path("/api")
@RequestScoped
public class InvoiceController {
    // all variable and injection 
    @POST
    @Consumes(MediaType.APPLICATION_JSON)
    @Produces(MediaType.APPLICATION_JSON)
    @Path("/invoice")
    @Timeout(250)
    @PermitAll
    public Response getInvoice(AuthTokenRequestModel atrm){
            SoupResponseInvoiceDetail srid = null;
            try{
                 srid = service.getInvoice(
                    atrm.getMcn(),"transactionId", atrm.getInvoiceNumber()
                 );
                 LOG.info("try block end");
            }
            catch(InterruptedException e)
            {
                LOG.info("Over here");
                return Response.status(401).build();
            }
          
            return Response.ok(srid).build();
        }

        return Response.status(401).build();
    }

 
    // all getter setter 
}

услуга

package com.ncr.invoice;

//all imports 

@Path("/")
@RegisterRestClient(configKey="invoice-api")
@ClientHeaderParam(name = "Authorization", value = "{basicAuth}")
public interface InvoiceService {

    @GET
    @Produces(MediaType.APPLICATION_JSON)
    @Path("/")
    public SoupResponseInvoiceDetail getInvoice(@QueryParam("id") String id,@QueryParam("txn_id") String txnId, @QueryParam("invoice") String invoice) throws InterruptedException;

    default String basicAuth() {
        String uName = ConfigProvider.getConfig().getValue("auth.username", String.class);
        String pwd = ConfigProvider.getConfig().getValue("auth.pwd", String.class);
        String creds =  uName + ":" + pwd;
        return "Basic " + Base64.getEncoder().encodeToString(creds.getBytes());
    }
}

Ошибка, которую я получаю 2021-01-07 13:07:42,286 INFO [com.ncr.inv.InvoiceController] (executor-thread-189) try block end 2021-01-07 13:07:42,555 ОШИБКА [io.und .req.io] (executor-thread-189) Запрос на обработку исключений 58a6d4b3-76c1-4a8b-b4a0-1e241219fb4d-4 в /api/invoice: org.jboss.resteasy.spi.UnhandledException: org.eclipse.microprofile.faulttolerance. исключения.TimeoutException: время ожидания [com.ncr.invoice.InvoiceController#getInvoice] истекло в org.jboss.resteasy.core.ExceptionHandler.handleApplicationException(ExceptionHandler.java:106) в org.jboss.resteasy.core.ExceptionHandler.handleException( ExceptionHandler.java:372) в org.jboss.resteasy.core.SynchronousDispatcher.writeException(SynchronousDispatcher.java:218) в org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:519) в org.jboss.resteasy .core.SynchronousDispatcher.lambda$invoke$4(SynchronousDispatcher.java:261) в org.jboss.resteasy.core.SynchronousDispatcher.lambda$preprocess$0(SynchronousDispa tcher.java:161) .........................................


exception quarkus microprofile timeoutexception fault
person deepak pandey    schedule 07.01.2021    source источник
comment
Похоже, вы хотите убедиться, что вызов внешней службы не займет слишком много времени? В этом случае просто переместите @Timeout(250) из конечной точки (InvoiceController.getInvoice) в клиентский интерфейс (InvoiceService.getInvoice). И в конечной точке ловите TimeoutException.   -  person Ladicek    schedule 07.01.2021
comment
@Ladicek - это сработало как шарм :) спасибо   -  person deepak pandey    schedule 07.01.2021

Ответы (1)


arrow_upward
0
arrow_downward

Мне кажется, что вам нужно сделать что-то вроде этого: @Provider открытый класс TimeoutExceptionMapper реализует ExceptionMapper { private static final Logger LOGGER = LoggerFactory.getLogger(java.lang.invoke.MethodHandles.lookup().lookupClass());
@Override public Response toResponse(исключение TimeoutException) { LOGGER.warn(exception.getMessage()); вернуть getResponse(); }

public static Response getResponse() {      
    ErrorResponse response = new ErrorResponse();
    response.setDescription("Operation timet out, try again later");
    return status(Response.Status.GATEWAY_TIMEOUT).entity(response).build();
}

}

person Lars Tore Hasle    schedule 11.01.2021