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

package org.apache.beam.sdk.io.rabbitmq
Transforms for reading and writing from RabbitMQ.
  • Classes
    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.