The following Red Hat Fuse Online integrations illustrate how to publish and subscribe to AMQP messages as well as how to consume RESTful APIs.
-
JSONValidationMicroService
: Red Hat Fuse Online integration that listens for JSON payloads from theJSON.VALIDATION.REQ
AMQP queue and then calls the Sample JSON Validation RESTful API for validation purposes. Successful validation responses are sent to theJSON.VALIDATION.OK.RESP
AMQP queue. Export archive : JSONValidationMicroService-export.zip -
_SampleValidationsPeriodicTrigger
: Red Hat Fuse Online integration that sends, periodically (every 5mn), constant JSON payload messages to theJSON.VALIDATION.REQ
AMQP queue so theJSONValidationMicroService
integration can validate them. Export archive : _SampleValidationsPeriodicTrigger-export.zip -
_ConsumeJsonValidationRespAMQPQueue
: Red Hat Fuse Online integration that consumes AMQP messages from theJSON.VALIDATION.OK.RESP
queue and logs them. Export archive : _ConsumeJsonValidationRespAMQPQueue-export.zip
The following screenshot shows the main Red Hat Fuse Online components involved in this use-case:
- Red Hat Fuse Online integrations
- Red Hat Fuse Online connections:
- Red Hat AMQ 7 Broker AMQP connection
- Sample JSON Validation API RESTful connection
- Sample JSON Validation API client connector
-
Import the integration
*.zip
archives in Fuse 7.7 Online: -
Update the Red Hat AMQ 7 Broker AMQP connection configuration according to your environment
-
Update the Sample JSON Validation API
connection
configuration according to your environmentas well as the Sample JSON Validation API
api client connector
-
Edit and save each integration before publishing them so the new connectors settings can be taken into account.
-
Once the Fuse 7.7 Online integrations are deployed and running, you should be able to see the AMQP queues that have been automatically created.