Rabbit MQ differs from Active MQ and other message brokers in a way that we need to post a message to an Exchange provided by it. This Exchange will then forward the message to a queue or topic based on the routing key property.
This adapter supports 3 types of data formats i.e. CSV, XML and JSON.
Mandatory Properties
- exchangeType – Pick List consisting of 4 values i.e. direct, topic, headers, fanOut. direct will be the default value. Its a String type value.
- exchangeName – Name of the exchange. Its a String type property.
- host- String type. Denotes the IP address of the Rabbit MQ server.
- port- String type. Denotes the port number of the Rabbit MQ server.
- routingKey – String type. Denotes the key with which an Exchange will bind in order to deliver or consume a message.
Common Properties
- username – String type. Contains the connection username.
- password – String type. Contains the connection password.
- isSSLRequired – Boolean. Default is false. Denotes whether to use SSL to connect to Message Broker.
- filetype – Pick List. Should contain CSV, XML, JSON, Binary & EXCEL
- separator – Pick list. Should contain following values , ; | Tab
- has_file_header – Boolean
- has_quotes – Boolean
- xmlRootTag- String type.
How to configure New Agent Control Board?
To configure new agent control board follow the given steps:
Step1: Create Integration. => Go custom Link => Clickon agent control board.
Step2: The custom link (Agent control board) Navigate to Dashboard of new agent control board.
Step 3: Create your own ” Connection destination file or you can select existing one”. Then click on Ping connection button. Make sure server is running.
Step4: Click on ping connection button to make it online.
How to check caching New Agent Control Board:
To check caching first you should create all the data.
Integration:
Interface Group:
Interfaces:
Mapping:
Here we are showing usecase with Flat CSV, Hierarchical XML and Hierarchical JSON payload format.
Usecase with Flat CSV:
Find the tutorial for “How to use RabbitMQ Inbound Adapter with CSV Payload?“