@Experimental(value=SOURCE_SINK)

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

Transforms for reading and writing using AMQP 1.0 protocol.

See: Description

Class Summary

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.

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

Transforms for reading and writing using AMQP 1.0 protocol.