Scénarios

L’exemple téléchargeable est beaucoup plus complet. Nous ne reprenons ici que l’entrée, un traitement et la sortie du flux de messages.

1. Flux d’entrée

Nous créons un message à partir d’une source externe en entrée. Nous configurons pour avoir tous les paramètres à leur maximum.

      SenderOptions<Integer, Person> senderOptions = senderOptions() 
         .producerProperty(ProducerConfig.ACKS_CONFIG, "all") 
         .producerProperty(ProducerConfig.MAX_BLOCK_MS_CONFIG, 
Long.MAX_VALUE) 
         .producerProperty(ProducerConfig.RETRIES_CONFIG, 
Integer.MAX_VALUE); 

Puis nous simulons une entrée :

      Flux<Person> srcFlux = source().flux(); 
    &n ...
Pour consulter la suite, découvrez le livre suivant :
couv_EPREAJASP.png
60-signet.svg
En version papier
20-ecran_lettre.svg
En version numérique
41-logo_abonnement.svg
En illimité avec l'abonnement ENI
130-boutique.svg
Sur la boutique officielle ENI
Précédent
Consommateur
Suivant
Points clés