Uses of Package
com.rabbitmq.stream
Package
Description
Main API for RabbitMQ Stream Java Client.
Implementations of AMQP 1.0
Codec
.Implementation-specific, non-public interfaces and classes of the RabbitMQ Stream Java Client.
-
ClassDescriptionUtility class to represent a hostname and a port.API to potentially change resolved node address to connect toContract to determine a delay between attempts of some task.API to easily configure byte capacities.API to check the content of message chunks.Codec to encode and decode messages.Callback API to confirm or fail a message.The status to confirm or fail a message.API to consume messages from a RabbitMQ Stream.API to configure and create a
Consumer
.Auto-tracking strategy.Filter configuration.Message flow configuration.Manual tracking strategy.Contract to determine when a subscription provides credits to get more messages.Chunk context.Behavior forMessageHandler.Context.processed()
calls.An interface for reacting to status changes of single active consumers.Information on the status change.TheEnvironment
is the main entry point to a node or a cluster of nodes.API to configure and create anEnvironment
.Helper to configure NettyHelper to configure TLS.API for outbound and inbound messages.API to configure and create aMessage
.API to set application properties.API to set message annotations.API to set message properties.Callback API for inbound messages.Information about the message.API to instrument operations in the stream client.API to specify an offset in a stream.API to send messages to a RabbitMQ Stream.API to create and configure aProducer
.Routing configuration for super streams (partitioned streams).Message properties.Strategy to route outbound messages to appropriate streams.Metadata on the super stream.API to configure and create a stream.The leader locator strategy.Super stream configuration.Generic stream exception.Statistics on a stream.Callback interface to customize a subscription.Context object for the subscription. -
ClassDescriptionCodec to encode and decode messages.API for outbound and inbound messages.API to configure and create a
Message
.API to set application properties.API to set message annotations.API to set message properties.Message properties. -
ClassDescriptionAPI to potentially change resolved node address to connect toContract to determine a delay between attempts of some task.API to easily configure byte capacities.API to check the content of message chunks.Codec to encode and decode messages.The
Environment
is the main entry point to a node or a cluster of nodes.API to configure and create anEnvironment
.Helper to configure NettyHelper to configure TLS.API for outbound and inbound messages.API to configure and create aMessage
.API to instrument operations in the stream client.API to specify an offset in a stream.The leader locator strategy. -