Package org.springframework.cloud.fn.supplier.jms

Class JmsSupplierConfiguration

java.lang.Object

org.springframework.cloud.fn.supplier.jms.JmsSupplierConfiguration

@Configuration(proxyBeanMethods=false)
@EnableConfigurationProperties(JmsSupplierProperties.class)
public class JmsSupplierConfiguration
extends Object

Constructor Summary

Constructors

Constructor	Description
JmsSupplierConfiguration()

Method Summary

Modifier and Type	Method	Description
AbstractMessageListenerContainer	container()
org.reactivestreams.Publisher<Message<byte[]>>	jmsPublisher(AbstractMessageListenerContainer container, org.springframework.cloud.fn.common.config.ComponentCustomizer<org.springframework.integration.jms.dsl.JmsMessageDrivenChannelAdapterSpec<?>> jmsMessageDrivenChannelAdapterSpecCustomizer)
Supplier<reactor.core.publisher.Flux<Message<?>>>	jmsSupplier(org.reactivestreams.Publisher<Message<?>> jmsPublisher)

Methods inherited from class java.lang.Object

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

Constructor Details

JmsSupplierConfiguration

public JmsSupplierConfiguration()

Method Details

jmsSupplier

@Bean
public Supplier<reactor.core.publisher.Flux<Message<?>>> jmsSupplier(org.reactivestreams.Publisher<Message<?>> jmsPublisher)

jmsPublisher

@Bean
public org.reactivestreams.Publisher<Message<byte[]>> jmsPublisher(AbstractMessageListenerContainer container,
 @Nullable
 org.springframework.cloud.fn.common.config.ComponentCustomizer<org.springframework.integration.jms.dsl.JmsMessageDrivenChannelAdapterSpec<?>> jmsMessageDrivenChannelAdapterSpecCustomizer)

container

@Bean
public AbstractMessageListenerContainer container()