Answers

I used a mix of Eduard's code, docs, EnsLib.PubSubOperation and some of my code

From my BP - I am calling the PubSubBo with a response of arrays that gives me targets in a string array

- BP then sends to all targets from a call inside a loop of targets array. The target of which is set dynamically from context of the loop element.

This gives me an extra functionality of putting some extra logic but most importantly in Visual Trace it doesn't look odd if target is a BP.If target is a BP and it is forwarded to, from a normal pubsubBo then in visual trace it shows a backward arrrow which is hard to explain to non tech people as it seems its going backward not forward. So forwarding it to targets from a BP is a better and cleaner option .

I am working on a production (PubSubService Produciton) that I have exclusively created to manage Publish/Subscriber operations (not business operation). The purpose of my production is to receive the publisher's request, gets its subscriber based on topics and send them a message to perform some updates at subscriber level. I also want to receive an acknowledgement of updates from each subscriber. It would be very help to have your code that you have implemented to get a better architectural understanding.

Example I made aims to make a resusable / generic pub-sub model which is passing a generic json message from start to finish and all bp/bo etc then need to transform / parse as per their own need once they receive the json. Do let me know if any queries

So this is how the flow works . 1. Service a. Read a csv file, loop through all recordsb. In each loop make one json msg and add it to the json array of messages (which is nothing but just an array of text as json is just text)Property RequestJSONArray As array Of %Text(MAXLEN = 10000);Property Topic As %String(MAXLEN = 100);

c. End of loop Send the array to the BPThis is few lines of code of Service

Step 2 : BPa. Bp gets the topic and json array of json recordsb. It calls the PubsubBo to get all the subscribers for this topicc. It loops through json recordsd. for each records. loops through the targets e. Sends the message to target via the Call activity of the BP

PFA : Screenshot of subscribers to a topic Note : This can be moulded as per the requirement. Each json msg can have a topic instead of the topic being outside of array etc.You can use your own messages instead of json too if you need.You can even send messages via the pubsub bo instead of just getting targets. (version attached)I mean all sorts of adjustments can be made as this is very generic and re-usable