default EventProcessingConfigurer.PooledStreamingProcessorConfiguration |
EventProcessingConfigurer.PooledStreamingProcessorConfiguration.andThen(EventProcessingConfigurer.PooledStreamingProcessorConfiguration other)
Returns a configuration that applies the given other configuration after applying this .
|
protected EventProcessor |
EventProcessingModule.pooledStreamingEventProcessor(String name,
EventHandlerInvoker eventHandlerInvoker,
Configuration config,
StreamableMessageSource<TrackedEventMessage<?>> messageSource,
EventProcessingConfigurer.PooledStreamingProcessorConfiguration processorConfiguration)
|
EventProcessingConfigurer |
EventProcessingModule.registerPooledStreamingEventProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSource,
EventProcessingConfigurer.PooledStreamingProcessorConfiguration processorConfiguration) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerPooledStreamingEventProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSource,
EventProcessingConfigurer.PooledStreamingProcessorConfiguration processorConfiguration)
|
EventProcessingConfigurer |
EventProcessingModule.registerPooledStreamingEventProcessorConfiguration(EventProcessingConfigurer.PooledStreamingProcessorConfiguration pooledStreamingProcessorConfiguration) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerPooledStreamingEventProcessorConfiguration(EventProcessingConfigurer.PooledStreamingProcessorConfiguration pooledStreamingProcessorConfiguration)
|
EventProcessingConfigurer |
EventProcessingModule.registerPooledStreamingEventProcessorConfiguration(String name,
EventProcessingConfigurer.PooledStreamingProcessorConfiguration pooledStreamingProcessorConfiguration) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerPooledStreamingEventProcessorConfiguration(String name,
EventProcessingConfigurer.PooledStreamingProcessorConfiguration pooledStreamingProcessorConfiguration)
|
default EventProcessingConfigurer |
EventProcessingConfigurer.usingPooledStreamingEventProcessors(EventProcessingConfigurer.PooledStreamingProcessorConfiguration pooledStreamingProcessorConfiguration)
|