See: Description
Class | Description |
---|---|
AmqpIO |
AmqpIO supports AMQP 1.0 protocol using the Apache QPid Proton-J library.
|
AmqpIO.Read |
A
PTransform to read/receive messages using AMQP 1.0 protocol. |
AmqpIO.Write |
A
PTransform to send messages using AMQP 1.0 protocol. |
AmqpMessageCoder |
A coder for AMQP message.
|
AmqpMessageCoderProviderRegistrar |
A
CoderProviderRegistrar for standard types used with AmqpIO . |