Package org.springframework.cloud.fn.supplier.rabbit

Class RabbitSupplierConfiguration

java.lang.Object
org.springframework.cloud.fn.supplier.rabbit.RabbitSupplierConfiguration
All Implemented Interfaces:
DisposableBean
@Configuration(proxyBeanMethods=false) @EnableConfigurationProperties(RabbitSupplierProperties.class) public class RabbitSupplierConfiguration extends Object implements DisposableBean
A source module that receives data from RabbitMQ.
Author:
Gary Russell, Chris Schaefer, Roger Perez, Chris Bono, Artem Bilan

  • Constructor Summary

    Constructors
    Constructor
    Description
    RabbitSupplierConfiguration()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer
    container(org.springframework.retry.interceptor.RetryOperationsInterceptor rabbitSourceRetryInterceptor)
     
    void
    destroy()
     
    org.reactivestreams.Publisher<Message<byte[]>>
    rabbitPublisher(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container, org.springframework.cloud.fn.common.config.ComponentCustomizer<org.springframework.integration.amqp.dsl.AmqpInboundChannelAdapterSMLCSpec> amqpMessageProducerCustomizer)
     
    org.springframework.retry.interceptor.RetryOperationsInterceptor
    rabbitSourceRetryInterceptor()
     
    Supplier<reactor.core.publisher.Flux<Message<byte[]>>>
    rabbitSupplier(org.reactivestreams.Publisher<Message<byte[]>> rabbitPublisher)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • RabbitSupplierConfiguration

      public RabbitSupplierConfiguration()

  • Method Details

    • container

      @Bean public org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container(org.springframework.retry.interceptor.RetryOperationsInterceptor rabbitSourceRetryInterceptor)

    • rabbitPublisher

      @Bean public org.reactivestreams.Publisher<Message<byte[]>> rabbitPublisher(org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer container, @Nullable org.springframework.cloud.fn.common.config.ComponentCustomizer<org.springframework.integration.amqp.dsl.AmqpInboundChannelAdapterSMLCSpec> amqpMessageProducerCustomizer)

    • rabbitSupplier

      @Bean public Supplier<reactor.core.publisher.Flux<Message<byte[]>>> rabbitSupplier(org.reactivestreams.Publisher<Message<byte[]>> rabbitPublisher)

    • rabbitSourceRetryInterceptor

      @Bean public org.springframework.retry.interceptor.RetryOperationsInterceptor rabbitSourceRetryInterceptor()

    • destroy

      public void destroy()
      Specified by:
      destroy in interface DisposableBean