Stream records from the agent to the testcontainer extension #330
Labels
Comments
remcowesterhoud
changed the title
RecordStreamSourceImpl. What if instead the extension just opened a long living stream to the engine, and it just pushed records out as they come in? You can register commit listeners to be notified of new records as they are appended, so you could just do that instead of having a more complicated way of reading records on demand. Happy to expand if that's not clear. The RecordStreamSourceImpl could then just be in the extension and wrap a plain list or the likes, and no serialization needs to take place during assertion
|
Note Heads up! We are building a new Java testing library for Camunda 8.6. The new library will replace Zeebe Process Test. |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
We keep an array of mapped records in the engine agent, mostly because we reuse the
RecordStreamSource. Instead the extension could open a long living stream to the engine, and push records out as they come in. We can register commit listeners to be notified of new records as they are appended. This would get rid of the more complicated way of reading records on demand, and no serialization needs to take place during assertionThe text was updated successfully, but these errors were encountered: