Configuration persistent streams

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.

Are there any examples how to do this?

Thanks
Klaus

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:-):

    val persistentStreamProperties = PersistentStreamProperties(
      processingGroup,
      initialSegmentCount,
      PersistentStreamSequencingPolicyProvider.SEQUENTIAL_PER_AGGREGATE_POLICY,
      emptyList(),
      HEAD_POSITION,
      null
    )

    eventProcessingConfigurer.registerSubscribingEventProcessor(processingGroup) { configuration ->
      PersistentStreamMessageSource(
        processingGroup,
        configuration,
        persistentStreamProperties,
        Executors.newScheduledThreadPool(workerThreads, AxonThreadFactory("WorkPackage")),
        batchSize
      )