Using a RabbitMQConnector in Stream mode to continuously listen for change events. It is set to not Auto Acknowledge messages as we do not want that to happen until confirmation it is written to the database. Was thinking to use a FeatureWriter as it chains outputs after writing. Doing this with Transaction Type of None and it inserts/updates the features in real-time fine. But the output from the FeatureWriter seems to always be blocking. We ideally want to use that output to acknowledge the message in RabbitMQ.
Would try a SQLExecutor but also need to write the shape to an ESRI geodatabase. Worst case can probably use a PythonCaller using arcpy. But would be nice to have a persistent connection with an actual writer.
Any thoughts on how to do something like this while keeping a data steam going?