All Classes and Interfaces
Class
Description
A AmqpBinarySerializer wrapper that presents an immutable view of a payload.
The methods that must be implemented by both source and sink.
A AmqpBinarySerializer wrapper that presents an immutable view of a payload.
A AmqpBinarySerializer wrapper that presents an immutable view of a payload.
A AmqpBinarySerializer wrapper that presents an immutable view of a payload.
Extracts data from the AMQP Message.
The AMQP Fragment.
The Setter for the AMQP fragment.
The properties found in the message object that are not otherwise handled with maps.
The OffsetManager Entry for the AMQP messages
Serializes sections of an AMQP message into a JSON format.
The configuration for an AMQP Source connector.
The configuration file for the AMQP source.
The AMQP source connector
The AMQP NativeSourceData implementation.
The AMQP native source data implementation of NativeSourceData.KeySerde.
Wraps ULID.Value and the Delivery for a streaming object.
The AMQP source task.
Automatically generated from filtered-source AmqpVersionInfo.java during
source-generate execution
A AmqpBinarySerializer wrapper that presents an immutable view of a payload.
Serializes an AMQP Message into a JSON format.