Simple use case here - publish and subscribes to events from Shopify.
Normally I would be doing this with orders, however, my trial Shopify account doesn't allow me to create orders, so I'm leveraging Products here. But, I know you are all experts at extrapolating.
Now someone may think of using Pub/Sub pattern available when creating a new integration in OIC. However, as you can see - it has been deprecated.
The publish to OIC integration style has been deprecated. Oracle recommends that you use app driven orchestration and use an invoke to publish a message into the OIC streaming service.
So let's take that advice -
Here is my Stream - ProductStream-NiallC
Now to the Connection creation in OIC - Please see my Shopify blog posts for details on how to create that connection. So now to the OCI Streaming connection creation -
Bootstrap Servers entry can be found here -
As you can see, it also contains the SASL username. You need to generate an Auth Token for the SASL Password -
Check out the OIC OCI Streaming adapter docs
for the steps to create the Trust Store. Test and Save the Connection -
Now to the "Publish" integration - very simple really -
I get the JSON for the PublishProduct request payload from the Shopify api docs here
Configuration of the PublishProduct action is as follows -
I activate and test by creating a new product in Shopify and then check out the stream -
So that's the Publish part addressed. Now to the subscribe - for this I use a Scheduled Integration -
The above is the final result - let's look at the integration in detail -
Subscribe2NewProduct is configured as follows -
Now to the message structure -
This I copy from the Recent Messages view from Streaming -
The only logic I add is a LOG action - to output the product name -
Now to testing the Subscribe -
I add 2 new products in Shopify -
I run the scheduled integration -