@Experimental(value=SOURCE_SINK)
See: Description
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.
|