Package com.rabbitmq.stream

package com.rabbitmq.stream

Main API for RabbitMQ Stream Java Client.

Related Packages

Package	Description
com.rabbitmq.stream.amqp	Classes for AMQP 1.0 support.
com.rabbitmq.stream.codec	Implementations of AMQP 1.0 Codec.
com.rabbitmq.stream.compression	Compression codec utilities to compress and decompress sub-entries.
com.rabbitmq.stream.impl	Implementation-specific, non-public interfaces and classes of the RabbitMQ Stream Java Client.
com.rabbitmq.stream.metrics	Package for metrics collection utilities.
com.rabbitmq.stream.sasl	SASL API for the RabbitMQ Stream Java Client.

Class	Description
Address	Utility class to represent a hostname and a port.
AddressResolver	API to potentially change resolved node address to connect to
AuthenticationFailureException	Exception to report a failed authentication attempt.
BackOffDelayPolicy	Contract to determine a delay between attempts of some task.
BackOffDelayPolicy.FixedWithInitialDelayAndTimeoutBackOffPolicy
BackOffDelayPolicy.FixedWithInitialDelayBackOffPolicy
ByteCapacity	API to easily configure byte capacities.
ChunkChecksum	API to check the content of message chunks.
ChunkChecksumValidationException	Indicate a checksum error for a chunk.
Codec	Codec to encode and decode messages.
Codec.EncodedMessage
ConfirmationHandler	Callback API to confirm or fail a message.
ConfirmationStatus	The status to confirm or fail a message.
Constants	Various constants (response codes, errors, etc)
Consumer	API to consume messages from a RabbitMQ Stream.
ConsumerBuilder	API to configure and create a Consumer.
ConsumerBuilder.AutoTrackingStrategy	Auto-tracking strategy.
ConsumerBuilder.FilterConfiguration	Filter configuration.
ConsumerBuilder.FlowConfiguration	Message flow configuration.
ConsumerBuilder.ManualTrackingStrategy	Manual tracking strategy.
ConsumerFlowStrategy	Contract to determine when a subscription provides credits to get more messages.
ConsumerFlowStrategy.Context	Chunk context.
ConsumerFlowStrategy.CreditOnChunkArrivalConsumerFlowStrategy	Strategy that provides the specified number of initial credits and a credit on each new chunk.
ConsumerFlowStrategy.MessageCountConsumerFlowStrategy	Strategy that provides the specified number of initial credits and a credit when the specified ratio of the chunk messages are processed.
ConsumerFlowStrategy.MessageProcessedCallback	Behavior for MessageHandler.Context.processed() calls.
ConsumerUpdateListener	An interface for reacting to status changes of single active consumers.
ConsumerUpdateListener.Context	Information on the status change.
Environment	The Environment is the main entry point to a node or a cluster of nodes.
EnvironmentBuilder	API to configure and create an Environment.
EnvironmentBuilder.NettyConfiguration	Helper to configure Netty
EnvironmentBuilder.TlsConfiguration	Helper to configure TLS.
Message	API for outbound and inbound messages.
MessageBuilder	API to configure and create a Message.
MessageBuilder.ApplicationPropertiesBuilder	API to set application properties.
MessageBuilder.MessageAnnotationsBuilder	API to set message annotations.
MessageBuilder.PropertiesBuilder	API to set message properties.
MessageHandler	Callback API for inbound messages.
MessageHandler.Context	Information about the message.
NoOffsetException
ObservationCollector<T>	API to instrument operations in the stream client.
OffsetSpecification	API to specify an offset in a stream.
Producer	API to send messages to a RabbitMQ Stream.
ProducerBuilder	API to create and configure a Producer.
ProducerBuilder.RoutingConfiguration	Routing configuration for super streams (partitioned streams).
Properties	Message properties.
RoutingStrategy	Strategy to route outbound messages to appropriate streams.
RoutingStrategy.Metadata	Metadata on the super stream.
StreamCreator	API to configure and create a stream.
StreamCreator.LeaderLocator	The leader locator strategy.
StreamCreator.SuperStreamConfiguration	Super stream configuration.
StreamDoesNotExistException	Exception to indicate a stream does not exist.
StreamException	Generic stream exception.
StreamNotAvailableException	Exception to indicate a stream is not available.
StreamStats	Statistics on a stream.
SubscriptionListener	Callback interface to customize a subscription.
SubscriptionListener.SubscriptionContext	Context object for the subscription.