Hi
I need to connect to a WebSocket which will send me hundreds of messages in a TEXT format. Those messages need to be acknowledged so the web socket stops sending the same messages overtime. To acknowledge those messages, I need to send an identifier back to the Origin service in a self contained WebSocket text message.
So far, my pipeline is as per below:
However, I realized the “Send response to Origin” was not sending back the identifier to the WS.
After reading the documentation, it seems that I could only use this block in a microservice pipeline. But the microservice pipeline works on origins which listen/read JSON-formatted data. And that’s where I am blocked. Indeed, my messages from the Web sockets are NOT in JSON and it s not a REST service.
Is there a way to send a text message back to a Web socket in Streamset? So I can properly ACK each message that have been processed successfully.
Thank you