Transform-Header und Nutzlast zu Json Knoten

Question

Ich versuche, so zu einem json Struktur zu bereichern Nutzlast mit Tasten einigen Kopf- und konvertieren:

{ 
"Header": { ["key" : "value", "key2": "value"]} 
"Payload": { "attribute" : "value" } 
} 

Mein Gateway wie folgt konfiguriert ist:

@MessagingGateway 
public static interface MailService { 
    @Gateway(requestChannel = "mail.input") 
    void sendMail(String body, @Headers Map<String,String> headers);   
} 

Hier ist mein Fluss:

@Bean 
public IntegrationFlow errorFlow(){ 
    return IntegrationFlows.from(recoveryChannel()) 
          .transform("payload.failedMessage")        
          .enrichHeaders(c -> c.header(FileHeaders.FILENAME, "emailErrors.json")) 
          .handle(this.fileOutboundAdapter()) 
          .get(); 
} 

Wie könnte ich dieses Problem lösen?

Danke.

Answer 1

Um die gesamte Nachricht an den JSON zu konvertieren, sollten Sie etwas tun:

.handle((p, h) -> MessageBuilder.withPayload(new GenericMessage<>(p, h))) 
.transform(Transformers.toJson()) 

Der Trick wie Transformers.toJson() ist nicht zu Kopf- und wandelt nur payload schert. Also müssen wir es ein bisschen hacken, indem wir das ganze message auf die payload setzen.

Seit ServiceActivator (Erdgeschoss des .handle()) gibt message wie wenn das Ergebnis Message<?> ist, haben wir Wahl nicht, es sei denn MessageBuilder bieten und Transformers.toJson() haben alle Infos für Ihren Anwendungsfall.

Answer 2

@SpringBootApplication 
public class So41223173Application { 

    public static void main(String[] args) { 
     ConfigurableApplicationContext context = SpringApplication.run(So41223173Application.class, args); 
     context.getBean("flow.input", MessageChannel.class) 
       .send(new ErrorMessage(new MessagingException(new GenericMessage<>(new Foo())))); 
     context.close(); 
    } 

    @Bean 
    public IntegrationFlow flow() { 
     return f -> f.transform("payload.failedMessage") 
       .enrichHeaders(c -> c.header("foo", "bar")) 
       .transform(toMap(), "transform") 
       .transform(Transformers.toJson()) 
       .handle(m -> System.out.println(m.getPayload())); 
    } 

    @Bean 
    public Transformer toMap() { 
     return new AbstractTransformer() { 

      @Override 
      protected Object doTransform(Message<?> message) throws Exception { 
       Map<String, Object> map = new LinkedHashMap<>(); 
       Map<String, Object> headers = new LinkedHashMap<>(message.getHeaders()); 
       headers.remove(MessageHeaders.ID); 
       headers.remove(MessageHeaders.TIMESTAMP); 
       map.put("headers", headers); 
       map.put("payload", message.getPayload()); 
       return map; 
      } 

     }; 

    } 

    public static class Foo { 

     String bar = "bar"; 

     public String getBar() { 
      return this.bar; 
     } 

     public void setBar(String bar) { 
      this.bar = bar; 
     } 

    } 

} 

Ergebnis

{"headers":{"foo":"bar"},"payload":{"bar":"bar"}}