@Experimental(value=SOURCE_SINK) public class AmqpIO extends java.lang.Object
It's also possible to use AMQP 1.0 protocol via Apache Qpid JMS connection factory and the Apache Beam JmsIO.
AmqpIO.Read can bind a AMQP listener endpoint and receive messages. It can
also connect to a AMPQ broker (such as Apache Qpid or Apache ActiveMQ).
AmqpIO.Read returns an unbounded
containing the received messages.
To configure a AMQP source, you have to provide a list of addresses where it will receive
messages. An address has the following form:
domain can be one of
host | host:port | ip | ip:port | name. NB: the
~ character allows to bind a AMQP
listener instead of connecting to a remote broker. For instance
bind a AMQP listener on any network interface on the 1234 port number.
The following example illustrates how to configure a AMQP source:
AmqpIO provides a sink to send
PCollection elements as messages.
As for the
AmqpIO.Write requires a list of addresses where to
send messages. The following example illustrates how to configure the
pipeline .apply(...) // provide PCollection<Message> .apply(AmqpIO.write());
|Modifier and Type||Class and Description|
|Modifier and Type||Method and Description|
public static AmqpIO.Read read()
public static AmqpIO.Write write()