@Experimental(value=SOURCE_SINK)

Package org.apache.beam.sdk.io.rabbitmq

Transforms for reading and writing from RabbitMQ.

See: Description

Class Summary

Class	Description
RabbitMqIO	A IO to publish or consume messages with a RabbitMQ broker.
RabbitMqIO.Read	A PTransform to consume messages from RabbitMQ server.
RabbitMqIO.Write	A PTransform to publish messages to a RabbitMQ server.
RabbitMqMessage	It contains the message payload, and additional metadata like routing key or attributes.

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

Transforms for reading and writing from RabbitMQ.