com.pivotal.rabbitmq.stream

Class TransactionalProducerStream<T>

java.lang.Object

com.pivotal.rabbitmq.stream.AbstractProducerStream<T,TransactionalProducerStream<T>>

com.pivotal.rabbitmq.stream.TransactionalProducerStream<T>

public class TransactionalProducerStream<T>
extends AbstractProducerStream<T,TransactionalProducerStream<T>>

Field Summary

Fields

Modifier and Type	Field and Description
protected Codec<T>	codec
protected Supplier<RabbitEndpoint>	endpoint
protected org.slf4j.Logger	log
protected String	name
static char	PARTITION_SEPARATOR_CHARACTER
protected SchemaManager	schemaManager
protected Class<T>	streamType
protected reactor.core.publisher.Mono<Topology>	topology

Fields inherited from class com.pivotal.rabbitmq.stream.AbstractProducerStream

attributes, deliveryGuarantees, router, routingStrategy, sender, unroutableEventStrategy, unserializableEventStrategy

Constructor Summary

Constructors

Constructor and Description
TransactionalProducerStream(Supplier<RabbitEndpoint> endpoint, reactor.core.publisher.Mono<Topology> topology, Class<T> type, SchemaManager schemaManager)

Method Summary

Modifier and Type	Method and Description
protected reactor.core.publisher.Flux<reactor.rabbitmq.OutboundMessage>	delayRetries(com.pivotal.rabbitmq.stream.OutboundMessageBuilder<T,TransactionalProducerStream<T>> messageBuilder, reactor.core.publisher.Flux<reactor.rabbitmq.OutboundMessage> downstream)
protected String	getApplicationId()
String	getName()
protected org.slf4j.Logger	logger(String stream)
<R extends Transaction<T>> reactor.core.publisher.Flux<R>	send(reactor.core.publisher.Flux<R> stream)
protected <R extends Transaction<T>> reactor.core.publisher.Flux<R>	send(reactor.core.publisher.Flux<R> stream, reactor.rabbitmq.SendOptions sendOptions)
protected void	setCodec(Codec<T> codec)

Methods inherited from class com.pivotal.rabbitmq.stream.AbstractProducerStream

getMaxInFlight, newSendOptions, resolveCodec, resolveSender, route, routeWith, trackReturnedMessages, whenNackByBroker, whenUnroutable, whenUnserializable, withAttributes, withAttributes, withCodec, withMaxInFight, withName

Methods inherited from class java.lang.Object

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

Field Detail

name

protected String name

streamType

protected Class<T> streamType

codec

protected Codec<T> codec

schemaManager

protected SchemaManager schemaManager

topology

protected reactor.core.publisher.Mono<Topology> topology

endpoint

protected Supplier<RabbitEndpoint> endpoint

log

protected final org.slf4j.Logger log

PARTITION_SEPARATOR_CHARACTER

public static final char PARTITION_SEPARATOR_CHARACTER

See Also:

Constant Field Values

Constructor Detail

TransactionalProducerStream

public TransactionalProducerStream(Supplier<RabbitEndpoint> endpoint,
                                   reactor.core.publisher.Mono<Topology> topology,
                                   Class<T> type,
                                   SchemaManager schemaManager)

Method Detail

send

public <R extends Transaction<T>> reactor.core.publisher.Flux<R> send(reactor.core.publisher.Flux<R> stream)

send

protected <R extends Transaction<T>> reactor.core.publisher.Flux<R> send(reactor.core.publisher.Flux<R> stream,
                                                                         reactor.rabbitmq.SendOptions sendOptions)

delayRetries

protected reactor.core.publisher.Flux<reactor.rabbitmq.OutboundMessage> delayRetries(com.pivotal.rabbitmq.stream.OutboundMessageBuilder<T,TransactionalProducerStream<T>> messageBuilder,
                                                                                     reactor.core.publisher.Flux<reactor.rabbitmq.OutboundMessage> downstream)

logger

protected org.slf4j.Logger logger(String stream)

getName

public String getName()

getApplicationId

protected String getApplicationId()

setCodec

protected void setCodec(Codec<T> codec)