Hi,
is there any detailed example on how to configure an event processor to use persistent streams?
Right now I am using PooledStreamingEventProcessors for all processing groups and I want to switch to persistent streams. But the docs under Subscribing Event Processor do tell much about the details on how to configure using the Java API.
Hi again,
after some searching in the Axon code I found out how to configure a persistent streams processor. Maybe interesting for others (beware, it’s Kotlin:-):
Thanks for answering your own question, @klauss42! I am confident it is virtually always helpful if all topics have some form of an answer, even if that comes from the one starting the topic.
Just wondering though, but what exactly were you missing from the description referred to? We can always make adjustments to the docs to make them clearer, of course.
Hey Steven,
If I remember correctly, I think what was missing in the docs was an example of how to construct the PersistentStreamMessageSource. That was not obvious to me.
The documentation currently only includes a comment like “* create/return PersistentStreamMessageSource *”.