In this tutorial, you will learn how to
This tutorial assumes:
Access to a Solace messaging service, Solace PubSub+, can be achieved in either one of the three flavours
This tutorial will walk you through setting up a Solace Cloud service instance, which also gives you access to the Event Portal. If you are interested in setting up a local broker running on Docker or a virtual machine check out the PubSub+ Event Broker: Software documentation
Navigate to the Create a New Account page and fill out the required information. No credit card required!
After you create your Solace Cloud account and sign in to the Solace Cloud Console, you'll be routed to the event mesh page.
Click on βCluster Manager' and all the messaging services associated with your account will show up if you have any already created. To create a new service, click either button as depicted in the image below:
Fill out all the details for your messaging service, and then click "Create" at the bottom of the page.
Your service should be ready to use in a couple seconds! πͺ
Boomi builds, deploys and manages all the processes in a concept called Atoms, which is a lightweight Java application that is deployed on a host with Internet access. Think of it as your single-tenant, single-node runtime engine. There are two deployment models for Atoms:
if you dont have an account, navigate to https://boomi.com/form/trial/ and sign up for a free account.
After you sign up for a Boomi platform account and login, you will have access to the Boomi AtomSphere - your one stop shop for all your integrations π€
You will see the menu at the top
Boomi Environments are synonymous to workspaces thats used for testing or production purposes. You need an environment to "attach" the atom to. You can read more about Boomi Environments on the Environment Management Boomi User Guide
Under the Manage menu, navigate to the Atom management and add a new environment
Give it a name and choose Test for the environment classification
In this tutorial, we will be setting up a local Atom.
You can either navigate to the links below for more information or follow the steps after
π Navigate to the Manage tab and click on Atom Management
π Click on +New and choose Atom
π Choose the operating system of choice in the Atom Setup box
π Open terminal and navigate to the location where the atom installer was installed. If you are using Linux or MacOS, make sure to change the mode of the file to make it executable. This is done as follows
cd <path_to_where_the_installer_is_installed>
chmod +x atom_install64.sh
π Run the installer ./atom_install64.sh
and follow the on-screen prompt to install the local atom. Make sure to select the previously created environment.
π Notes on Docker installation
If you have access to the docker version of the atom installer, you can follow the following step.
The installer is a shell script that you run locally and automatically configure your docker setup
./atomdocker_install64.sh -h
for more information on how to run it/var/boomi
directory because the script assumes it already exists and make sure its owned by the current user /var/boomi/
after you create itchown $USER .
πββοΈ Run the atom
Execute the atom docker installation shell script as follows./atomdocker_install64.sh -n
At this point, you can confirm that the Atom has been created and linked to your AtomSphere when you navigate to the Atom Management in the Manage tab and you will see your newly created atom under the Unattached Atoms section
If you did not attach the atom directly fro the Wizard installer or you are manually running the atom on a docker image, you can follow the following steps to attach the atom to the newly created Environment. To do so, select your newly created environment and search for your atom to attach it
Your free trial of Solace PubSub+ Cloud comes with the Event Portal, which helps you visualize the structure of event-driven architectures. The trial also includes a sample architecture called Acme Rideshare, that we'll use for this lab.
For our purposes:
Passenger App: will mock an event publisher
Ride Requested: is an event with a JSON schema payload representing a ride request
Driver Management: will be a simple Boomi flow, which will pick up the ride request and write it to the process log. Very simple π€
Two things to note here:
Now back to the Boomi AtomSphere!
π Click on the New button to create a new component
π Make sure the Type is Process. Give it a name and folder to be saved in
π Drag and drop it into the canvas
π Configure the Start shape to be a Solace PubSub+ Connector with the a Listen action as seen in the screenshot below
π In the Connection section, click on the + icon to configure the connection parameters
π Fill in the connection parameters with the Host, Message VPN Name, Client Username and Password. This is obtained by navigating back to the Solace PubSub+ Cloud Manager console, clicking on the previously created service and navigating to the Connect tab. Note that you will have to expand the "Solace Messaging" menu to get the connection details
π One more piece of information you'll need is an Event Portal token (this lets you import in the topic string and schema from the previously designed architecture). In Solace Cloud console, scroll all the way to the bottom of the left column, and click on the account management icon, then select Token Management.
π Click on the "Create Token" button in the upper right.
π Name the token "Boomi UI access"
π Scroll all the way to the bottom of the page and enable the Event Portal Read permission.
π Click on Generate Token
π Copy the generated token (make sure to grab it all), and paste it into the Event Portal API Token field in Boomi.
π Test the connection, by clicking on the Test Connection button. Note: Choose your Atom here
Back to the Solace Shape configuration, click on the + icon for the Operation section to configure the operation parameters as seen in the screenshot below
π Assign the Mode to Persistent Transacted
π Fill in the destination to the name of the queue. Note: you can either type in a name of a queue that is previously created on the broker or you can have a totally new queue and the connector will automatically deal with the creation of the queue on the broker. Magic.
π Click on the Import Button in the Upper Right. Select your atom and the Solace connection that you just created, then click on Next.
Boomi grabs the events available to you from the Event Portal, and lists them in a drop down box
π Pick the RideRequested event, click Next, then Finish.
Now check out our Connector Operation: The data format from the Event Portal is now a Boomi Profile (click on the pencil to see more) and the topic string is filled in for us.
π Now your Canvas should look like this with the newly added shape
In order to test out the end to end connection and make sure that the events sent from the Solace PubSub+ broker are being received by the Solace Boomi Connector, we want to add a way to log the events received. To do so, lets go ahead and add a Notify shape
π Search for and drag the notify shape into the canvas from the "Search Shapes" section
π Configure the Notify shape to log the payload received from the message sent
Note that {1}
in the Boomi context means variables. Click on the +
icon to add a new variable and choose the type to be Current Data
To connect everything together, we will need to package the newly created process flow and deploy it on the locally running Atom
π Click on the Create Package button
π The newly created component will be automatically selected by default
π Click Next to add details. No need to add any more details
π Click create package and you will see this notification
π Click on the Deploy button and choose the Environment that you created previously
π Click Next until you get to the Review Deploy step
π Click on the Deploy button!
π Navigate back to your Solace Cloud console, select the messaging service and navigate to the Try Me! tab
π In the Publisher section, click on the Connect button, change the topic to be acme/rideshare/ride/requested/rideX
(since we have our queue subscribing to this topic, remember!) and update the message body to whatever you want
π Smash that Publish button.
π From the Boomi AtomSphere, navigate to the Process Reporting section under the Manage tab
You will see the process reporting menu with your newly created NewProcess process. Note that you can click on the refresh icon
π Click on the view process logs icon
You're done!
β
Sign up for a Solace PubSub+ Cloud account and configure a messaging service broker with a queue
β
Sign up for a Boomi AtomSphere account and setup a Solace Pubsub+ Connector for a listen configuration and bind to a message queue
β
Send events to the same topic the queue is subscribed to
β
Check out more information on the Solace Connector in the PubSub+ Connector Hub page
Thanks for participating in this codelab! Let us know what you thought in the Solace Community Forum!