Please enable JavaScript.

Coggle requires JavaScript to display documents.

spring cloud stream - Coggle Diagram

- - - - this is a message source
    - - this is a message handler
      - accepts 1 argument and produces a result
      - Interface Function<T,R>
        Where T - the type of input to the function
        and R- the type of result of the function
    - - this is a message handler
      - Accepts only 1 input and returns nothing
  - - - name
        
        spring.cloud.stream.bindings.input.destination=myQueue
        
        By default the generated by SCS
        
        provide a custom name
        
        spring.cloud.stream.function.bindings.<binding-name>
  - - - Auto bind bean of type java.util.function.[Supplier/Consumer/Function]
      - Specify spring.cloud.function.definition to bind explicitely
    - - doesn't subscribe to any in-bound destination
      - Can be
        
        imperative
        
        triggering
        
        in every 1 second
        
        Customize
        
        done by framework
        
        reactive
        
        triggering
        
        only once
        
        use @PollableBean annotation to call it periodically
      - Threading?
    - - Reactive
        
        has no return type
      - Doc
- - - - components providing integration with external messaging system
    - - Kafka
      - RabbitMQ
  - - - custom binder implementation
  - - - Message-driven (Asynchronous)
      - Polled (Synchronous)
        
        use this if you want to control the rate at which messages are processed
    - - Consumer Group subscription are durable
      - Anonymous subscription are non-durable
- - - - specifically for Apache Kafka Stream API