com.pivotal.rabbitmq.stream

Class StreamBuilder

java.lang.Object

com.pivotal.rabbitmq.stream.StreamBuilder

public class StreamBuilder
extends Object

Constructor Summary

Constructors

Constructor and Description
StreamBuilder(Supplier<RabbitEndpoint> rabbit, reactor.core.publisher.Mono<Topology> topology, SchemaManager schemaManager)

Method Summary

Modifier and Type	Method and Description
<T> ConsumerStream<T>	createConsumerStream(String queueName, Class<T> type)
<T> ProducerStream<T>	createProducerStream(Class<T> type)
<T> TransactionalConsumerStream<T>	createTransactionalConsumerStream(String queueName, Class<T> type)
<T> TransactionalProducerStream<T>	createTransactionalProducerStream(Class<T> type)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamBuilder

public StreamBuilder(Supplier<RabbitEndpoint> rabbit,
                     reactor.core.publisher.Mono<Topology> topology,
                     SchemaManager schemaManager)

Method Detail

createProducerStream

public <T> ProducerStream<T> createProducerStream(Class<T> type)

createConsumerStream

public <T> ConsumerStream<T> createConsumerStream(String queueName,
                                                  Class<T> type)

createTransactionalProducerStream

public <T> TransactionalProducerStream<T> createTransactionalProducerStream(Class<T> type)

createTransactionalConsumerStream

public <T> TransactionalConsumerStream<T> createTransactionalConsumerStream(String queueName,
                                                                            Class<T> type)