Comment guider un nouveau message qui contient l'ID de corrélation actuel dans un flux d'exception

Question

Après le séparateur, une exception se produit lors du traitement d'un message. Je veux traiter cette exception et diriger vers le canal commun un nouveau message avec l'identifiant de corrélation de ce message qui a produit l'exception et un en-tête spécial qui indique l'erreur.

Je l'ai essayé de cette façon:

@Bean 
public IntegrationFlow socialMediaErrorFlow() { 
    return IntegrationFlows.from("socialMediaErrorChannel") 
      .wireTap(sf -> sf.handle("errorService", "handleException")) 
      .handle((p, h) -> MessageBuilder.withPayload(p).copyHeaders(h).setHeader("ERROR", true).build()) 
      .channel("directChannel_2") 
      .get(); 
} 

Mais les agrégateurs renvoie cette erreur:

MessageHandlingException: error occurred in message handler [org.springframework.integration.dsl.AggregatorSpec$InternalAggregatingMessageHandler#0]; nested exception is java.lang.IllegalStateException: Null correlation not allowed. Maybe the CorrelationStrategy is failing? 

Je ne peux pas copier l'ID de corrélation dans l'en-tête du message.

Est-ce que quelqu'un sait que je fais mal? Merci d'avance.

Answer 1

Le message que le canal d'erreur est arrivé est ErrorMessage. Son payload est (généralement) MessagingException. Celui-ci, à son tour, a la propriété failedMessage.

Qu'est-ce que vous avez besoin est quelque chose comme ceci:

.<MessagingException>handle((p, h) -> MessageBuilder.fromMessage(p.getFailedMessage()).setHeader("ERROR", true).build()) 

Vous n'avez pas besoin de copier les en-têtes, car ils sont déjà là dans le failedMessage. Le ErrorMessage ne s'en soucie pas (et il ne peut pas) sur les en-têtes car il s'agit juste de l'exception.