org.springframework.cloud.fn.supplier.jms

Class JmsSupplierConfiguration

java.lang.Object

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

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

Constructor Summary

Constructors

Constructor and Description
JmsSupplierConfiguration()

Method Summary

Modifier and Type	Method and Description
org.springframework.jms.listener.AbstractMessageListenerContainer	container()
org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>>	jmsPublisher()
Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>>	jmsSupplier(org.reactivestreams.Publisher<org.springframework.messaging.Message<?>> jmsPublisher, org.springframework.integration.jms.JmsMessageDrivenEndpoint adapter)

Methods inherited from class java.lang.Object

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

Constructor Detail

JmsSupplierConfiguration

public JmsSupplierConfiguration()

Method Detail

jmsSupplier

@Bean
public Supplier<reactor.core.publisher.Flux<org.springframework.messaging.Message<?>>> jmsSupplier(org.reactivestreams.Publisher<org.springframework.messaging.Message<?>> jmsPublisher,
                                                                                                         org.springframework.integration.jms.JmsMessageDrivenEndpoint adapter)

jmsPublisher

@Bean
public org.reactivestreams.Publisher<org.springframework.messaging.Message<byte[]>> jmsPublisher()

container

@Bean
public org.springframework.jms.listener.AbstractMessageListenerContainer container()