Consider a simple flow with a simple AMQP sender node which sends a message to a queue on a running broker and an AMQP receiver node which reads from the queue.
The sender flow is composed of three following nodes :
- inject : it's used in order to inject the message to set inside the AMQP message body and send to the queue on the broker. The msg.payload field is set to "Hello";
- function : it's a function node (named "toAMQPmessage") which get the message from the previous inject node and copis its payload in the "body" field expected as AMQP message by the AMQP sender node in order to send it correctly;
- amqp-sender : an AMQP sender node which is configured to connect to a broker running on the local machine. It receives the message from the previous function node and sends it to the configured queue;
The receiver flow is composed of two following nodes :
- amqp-receiver : an AMQP sender node which is configured to connect to a broker running on the local machine. It reads message from a queue and provides it as output;
- debug : this debug node is used in order to show the "body" of the received AMQP message to the debug window;
