com.pivotal.rabbitmq.stream

Class AbstractProducerStream<T,P extends com.pivotal.rabbitmq.stream.BaseStream<T>>

java.lang.Object

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

Direct Known Subclasses:

ProducerStream, TransactionalProducerStream

public abstract class AbstractProducerStream<T,P extends com.pivotal.rabbitmq.stream.BaseStream<T>>
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected EventAttributes<T,P>	attributes
protected Codec<T>	codec
protected EventFailureStrategy<T,P>	deliveryGuarantees
protected Supplier<RabbitEndpoint>	endpoint
protected org.slf4j.Logger	log
protected String	name
static char	PARTITION_SEPARATOR_CHARACTER
protected BiConsumer<EventMessageBuilder,T>	router
protected RoutingStrategies<T,P>	routingStrategy
protected SchemaManager	schemaManager
protected reactor.rabbitmq.Sender	sender
protected Class<T>	streamType
protected reactor.core.publisher.Mono<Topology>	topology
protected UnroutableEventHandling<T,P>	unroutableEventStrategy
protected UnserializableEventHandling<T,P>	unserializableEventStrategy

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected String	getApplicationId()
protected int	getMaxInFlight(reactor.rabbitmq.SendOptions sendOptions)
String	getName()
protected abstract org.slf4j.Logger	logger(String stream)
protected reactor.rabbitmq.SendOptions	newSendOptions()
protected Codec<T>	resolveCodec()
protected reactor.rabbitmq.Sender	resolveSender()
RoutingStrategies<T,P>	route()
P	routeWith(BiConsumer<EventMessageBuilder,T> router)
protected void	setCodec(Codec<T> codec)
protected boolean	trackReturnedMessages()
EventFailureStrategy<T,P>	whenNackByBroker()
UnroutableEventHandling<T,P>	whenUnroutable()
UnserializableEventHandling<T,P>	whenUnserializable()
EventAttributes<T,P>	withAttributes()
EventAttributes<T,P>	withAttributes(boolean propagate)
P	withCodec(Codec codec)
P	withMaxInFight(Integer value)
P	withName(String name)

Methods inherited from class java.lang.Object

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

Field Detail

attributes

protected EventAttributes<T,P extends com.pivotal.rabbitmq.stream.BaseStream<T>> attributes

routingStrategy

protected RoutingStrategies<T,P extends com.pivotal.rabbitmq.stream.BaseStream<T>> routingStrategy

deliveryGuarantees

protected EventFailureStrategy<T,P extends com.pivotal.rabbitmq.stream.BaseStream<T>> deliveryGuarantees

unroutableEventStrategy

protected UnroutableEventHandling<T,P extends com.pivotal.rabbitmq.stream.BaseStream<T>> unroutableEventStrategy

unserializableEventStrategy

protected UnserializableEventHandling<T,P extends com.pivotal.rabbitmq.stream.BaseStream<T>> unserializableEventStrategy

sender

protected reactor.rabbitmq.Sender sender

router

protected BiConsumer<EventMessageBuilder,T> router

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

AbstractProducerStream

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

Method Detail

withAttributes

public EventAttributes<T,P> withAttributes()

withAttributes

public EventAttributes<T,P> withAttributes(boolean propagate)

route

public RoutingStrategies<T,P> route()

routeWith

public P routeWith(BiConsumer<EventMessageBuilder,T> router)

whenUnroutable

public UnroutableEventHandling<T,P> whenUnroutable()

whenNackByBroker

public EventFailureStrategy<T,P> whenNackByBroker()

whenUnserializable

public UnserializableEventHandling<T,P> whenUnserializable()

withName

public P withName(String name)

withCodec

public P withCodec(Codec codec)

withMaxInFight

public P withMaxInFight(Integer value)

resolveCodec

protected Codec<T> resolveCodec()

newSendOptions

protected reactor.rabbitmq.SendOptions newSendOptions()

trackReturnedMessages

protected boolean trackReturnedMessages()

getMaxInFlight

protected int getMaxInFlight(reactor.rabbitmq.SendOptions sendOptions)

resolveSender

protected reactor.rabbitmq.Sender resolveSender()

getName

public String getName()

getApplicationId

protected String getApplicationId()

setCodec

protected void setCodec(Codec<T> codec)

logger

protected abstract org.slf4j.Logger logger(String stream)