AMQP broker message In

LDIO Component Name: Ldio:AmqpIn see reference guide
Apache Nifi Component Name: ConsumeAMQP see Apache Nifi reference guide

Consumes AMQP Messages from an AMQP Broker using the AMQP protocol. Each message that is received from the AMQP Broker will be emitted downstream the pipeline.

The LDIO AMQP In listens to messages from an AMQP 1.0 queue.

graph LR
    L[AMQP broker] --> H[AMQP message In]
    H --> S[LDES server]

    subgraph Publishing Pipeline
    H
    end