Метод setExpectedResponseType () в HttpRequestExecutingMessageHandler - PullRequest
Новая
       11

Метод setExpectedResponseType () в HttpRequestExecutingMessageHandler

0 голосов
/ 27 апреля 2018

Ниже приведена конфигурация HttpRequestExecutingMessageHandler 

@ServiceActivator(inputChannel = "rtpRequestChannel")
@Bean
public MessageHandler httResponseMessageHandler(MessageChannel rtpResponseChannel) {
    HttpRequestExecutingMessageHandler handler = new HttpRequestExecutingMessageHandler(
            "http://localhost:8080/rtp");
    handler.setHttpMethod(HttpMethod.POST);
    handler.setOutputChannel(rtpResponseChannel);
    handler.setShouldTrack(true);
    handler.setStatsEnabled(true);
    return handler;
}

Ниже приведен метод POST в классе контроллера REST: 

@RequestMapping(value = "/rtp", method = RequestMethod.POST)
@ResponseBody
public ResponseEntity<RTPResponse> persistRTP(@RequestBody RTPRequest request) {
    System.out.println("In post method " + request);
    if (request != null) {
        return new ResponseEntity<RTPResponse>(new RTPResponse("12:12:2017", "Test", null, "100", "100"), HttpStatus.OK);
    }

    return new ResponseEntity<RTPResponse>(new RTPResponse("12:12:2017", "Dummy", null, "Dummy", "Dummy"), HttpStatus.OK);
}

Ниже приведена конфигурация метода активации службы: 

@Override
@ServiceActivator(inputChannel="rtpResponseChannel")
public void makeCall(ResponseEntity<RTPResponse> message) {
    System.out.println("Message: " + message.getBody());
    System.out.println(message.getClass().getCanonicalName());
}

Я получаю ноль в теле объекта ResponseEntity. Какая конфигурация мне не хватает?

Редактировать 1:

Когда я использую setExpectedResponseType(), с той же конфигурацией контроллера, что и выше. 

@ServiceActivator(inputChannel = "rtpRequestPostOperationRequestChannel")
@Bean
public MessageHandler httResponseMessageHandler(MessageChannel rtpRequestPostOperationResponseChannel) {
    HttpRequestExecutingMessageHandler handler = new HttpRequestExecutingMessageHandler(
            "http://localhost:8080/rtp");
    handler.setHttpMethod(HttpMethod.POST);
    handler.setOutputChannel(rtpRequestPostOperationResponseChannel);
    handler.setExpectedResponseType(RTPResponse.class);
    return handler;
}

Объект RTPResponse не обернут в ResponseEntity.

Я получаю ошибку, как показано ниже: 

Caused by: org.springframework.expression.spel.SpelEvaluationException: EL1004E: Method call: Method makeCall(rtp.model.RTPResponse) cannot be found on rtp.RTPRequestServiceClient type

Редактировать 2:

Другими словами, какую конфигурацию я должен использовать на HttpRequestExecutingMessageHandler, чтобы получить объект сообщения, чтобы у меня было извлеченное тело в полезной нагрузке сообщения и все заголовки к MessageHeaders, включая статус.

Я пытался использовать GenericMessage, передаваемый методу setExpectedResponseType класса HttpRequestExecutingMessageHandler.

Но это дало мне ошибку, как показано ниже:

Can not construct instance of org.springframework.messaging.support.GenericMessage: no suitable constructor found, can not deserialize from Object value (missing default constructor or creator, or perhaps need to add/enable type information?)

1 Ответ

0 голосов
/ 27 апреля 2018

Но ты сам сказал - setExpectedResponseType().

Вы действительно пропустите именно эту конфигурацию.

В этом случае body объекта ответа пуст: 

private class ResponseEntityResponseExtractor<T> implements ResponseExtractor<ResponseEntity<T>> {

    @Nullable
    private final HttpMessageConverterExtractor<T> delegate;

    public ResponseEntityResponseExtractor(@Nullable Type responseType) {
        if (responseType != null && Void.class != responseType) {
            this.delegate = new HttpMessageConverterExtractor<>(responseType, getMessageConverters(), logger);
        }
        else {
            this.delegate = null;
        }
    }

    @Override
    public ResponseEntity<T> extractData(ClientHttpResponse response) throws IOException {
        if (this.delegate != null) {
            T body = this.delegate.extractData(response);
            return ResponseEntity.status(response.getRawStatusCode()).headers(response.getHeaders()).body(body);
        }
        else {
            return ResponseEntity.status(response.getRawStatusCode()).headers(response.getHeaders()).build();
        }
    }
}

Если вы не хотите указывать Class<?> для этой опции, вы можете использовать: 

/**
 * Specify the {@link Expression} to determine the type for the expected response
 * The returned value of the expression could be an instance of {@link Class} or
 * {@link String} representing a fully qualified class name.
 * @param expectedResponseTypeExpression The expected response type expression.
 * Also see {@link #setExpectedResponseType}
 */
public void setExpectedResponseTypeExpression(Expression expectedResponseTypeExpression) {

вместо этого. В этом случае вы действительно можете разрешить целевой ожидаемый тип ответа для requestMessage, а также получить доступ ко всему BeanFactory для некоторых других вызовов bean-компонентов.

...