com.pivotal.rabbitmq.stream

Class ConsumerStream<T>

java.lang.Object

com.pivotal.rabbitmq.stream.AbstractConsumerStream<T,T>

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

public class ConsumerStream<T>
extends AbstractConsumerStream<T,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.AbstractConsumerStream

CONSUMER_TAG_SEPARATOR_CHARACTER, consumerTagSequence, MAX_CONSUMER_TAG_LENGTH, prefetch, queueName, receiver

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected String	getApplicationId()
String	getName()
protected org.slf4j.Logger	logger(String stream)
protected reactor.core.publisher.Flux<T>	receiveFromPartitionedQueue(Collection<reactor.rabbitmq.QueueSpecification> queuePartitions)
protected reactor.core.publisher.Flux<T>	receiveFromSingleQueue()
protected Codec<T>	resolveCodec()
protected void	setCodec(Codec<T> codec)
IllegalEventHandler<T,ConsumerStream<T>>	whenReceiveIllegalMessages()
AvroCodecConfigurer<T,ConsumerStream<T>>	withAvroCodec()

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

consumeOptions, defaultConsumerSettings, receive, resolveReceiver, toEventType

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

ConsumerStream

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

Method Detail

whenReceiveIllegalMessages

public IllegalEventHandler<T,ConsumerStream<T>> whenReceiveIllegalMessages()

withAvroCodec

public AvroCodecConfigurer<T,ConsumerStream<T>> withAvroCodec()

resolveCodec

protected Codec<T> resolveCodec()

receiveFromSingleQueue

protected reactor.core.publisher.Flux<T> receiveFromSingleQueue()

Specified by:

receiveFromSingleQueue in class AbstractConsumerStream<T,T>

receiveFromPartitionedQueue

protected reactor.core.publisher.Flux<T> receiveFromPartitionedQueue(Collection<reactor.rabbitmq.QueueSpecification> queuePartitions)

Specified by:

receiveFromPartitionedQueue in class AbstractConsumerStream<T,T>

logger

protected org.slf4j.Logger logger(String stream)

getName

public String getName()

getApplicationId

protected String getApplicationId()

setCodec

protected void setCodec(Codec<T> codec)