Spring統合フローがHTTP 400で応答する

Question

"routingkey"メッセージヘッダーを必要とするバネ統合フローがあります。これが存在しない場合は、HTTP 400の応答をクライアントに送り返したいと思います。どうやってやるの？以下は、decideRoutingKeyメソッドがルーティングキーがヘッダーとして渡されたかどうかを判断できるところです。

@Bean 
public IntegrationFlow webToRabbit(RabbitTemplate amqpTemplate) 
{ 
    return IntegrationFlows 
      .from 
      (
       Http.inboundGateway("/tunnel") 
        .replyTimeout(Integer.valueOf(timeout)) 
        .mappedRequestHeaders("*") 
        .mappedResponseHeaders("*") 
      ) 
      .log() 
      .handle 
      (
       Amqp.outboundGateway(amqpTemplate) 
        .exchangeName(exchangeName) 
        .routingKeyFunction(f->determineRoutingKey(f)) 
        .mappedRequestHeaders("*") 
        .mappedReplyHeaders("*") 
      ) 
      .log() 
      .bridge(null) 
      .get(); 
} 

private String determineRoutingKey(Message<?> message) 
{ 
    MessageHeaders headers = message.getHeaders(); 
    if(headers.containsKey(HEADER_ROUTINGKEY)) 
    { 
     String routingKey = Objects.toString(headers.get(HEADER_ROUTINGKEY)); 
     log.debug("Using routing key: " + routingKey); 
     return routingKey; 
    } 
    else 
    { 
     log.error("Headers found: " + Objects.toString(headers)); 

     //Here I get an exception stating that MessageHeaaders is immutable 
     message.getHeaders().put(HttpHeaders.STATUS_CODE, HttpStatus.BAD_REQUEST); 
     return null; 
    } 
} 

ご協力いただきありがとうございます。何が必要そう

private HttpStatus resolveHttpStatusFromHeaders(MessageHeaders headers) { 
    Object httpStatusFromHeader = headers.get(org.springframework.integration.http.HttpHeaders.STATUS_CODE); 
    return buildHttpStatus(httpStatusFromHeader); 
} 

、普通のです（エラーメッセージの文字列？）回答とhttp_statusCodeヘッダなどの適切なHttpStatus.BAD_REQUEST：

Answer 1

があるようなロジックがあります。

例外はありません。

UPDATE

あなたは流れの真ん中にあり、それは遠く回答からまだあるので、あなたはその例外的なアプローチに固執することができます。

Http.inboundGateway("/tunnel") 
    .errorChannel("httpErrorFlow.input") 
... 

@Bean 
public IntegrationFlow httpErrorFlow() { 
    return f -> f 
      .<RuntimeException, Message<?>>transform(payload -> { 
       if (payload.getCause() instanceof MyRoutingKeyException) { 
        return MessageBuilder.withPayload("Bad routing key") 
          .setHeader(HttpHeaders.STATUS_CODE, HttpStatus.BAD_REQUEST) 
          .build(); 
       } 
       throw payload; 
      }); 
} 

しかし、再び：

は何が適切な400応答を返すためにそこにしなければならないことはHttp.inboundGateway()上errorChannel戻りにいくつかの簡単な変圧器の適切なHttpHeaders.STATUS_CODEヘッダとMessageであるあなたがすることはできませんだけで例外をスローします。

です。