2017-06-02 1 views
0

J'ai le flux d'intégration ci-dessous en utilisant Java DSL et je veux ajouter requestPayloadType comme java.util.HashMap. Comment je fais ça? Je veux l'entrée JSON à auto reconnu comme JSON et non comme octetComment puis-je définir le paramètre requestPayloadType à un HashMap en utilisant Java DSL

public IntegrationFlow NotificationFlow() { 
    return IntegrationFlows 
      .from(Http.inboundChannelAdapter("/passenger") 
        .requestChannel(inputChannel()) 
        .autoStartup(true) 
        .id("httpInnboundPass") 
        .requestMapping(r -> r.consumes("application/json")) 
        .**requestPayloadType**() 
        ) 
      .enrichHeaders(hes -> hes.header(HttpHeaders.ACCEPT, MediaType.APPLICATION_JSON_VALUE)) 
      .channel("inputChannel") 
      .get(); 
} 

Répondre

1

Votre question est pas claire. Il y a vraiment cette méthode là:

Http.inboundChannelAdapter("/passenger") 
       .requestPayloadType(HashMap.class)