Package org.apache.beam.sdk.io.amqp

package org.apache.beam.sdk.io.amqp

Transforms for reading and writing using AMQP 1.0 protocol.

Related Packages

Package	Description
org.apache.beam.sdk.io	Defines transforms for reading and writing common storage formats, including invalid reference org.apache.beam.sdk.io.AvroIO , and TextIO.

Classes

Class	Description
AmqpIO	AmqpIO supports AMQP 1.0 protocol using the Apache QPid Proton-J library.
AmqpIO.Read	A PTransform to read/receive messages using AMQP 1.0 protocol.
AmqpIO.Write	A PTransform to send messages using AMQP 1.0 protocol.
AmqpMessageCoder	A coder for AMQP message.
AmqpMessageCoderProviderRegistrar	A CoderProviderRegistrar for standard types used with AmqpIO.