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.
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:
pipeline .apply(...) // provide PCollection<Message> .apply(AmqpIO.write());
|Modifier and Type||Class and Description|