@Test void testPackageOfObject() { String expectedPackageName = EventProcessingModule.class.getPackage().getName(); assertEquals(expectedPackageName, EventProcessingModule.packageOfObject(this)); }
protected static String packageOfObject(Object object) { return object.getClass().getName().replace("." + object.getClass().getSimpleName(), ""); }
EventProcessingModule implements ModuleConfiguration, EventProcessingConfiguration, EventProcessingConfigurer { protected static String packageOfObject(Object object) { return object.getClass().getName().replace("." + object.getClass().getSimpleName(), ""); } }
EventProcessingModule implements ModuleConfiguration, EventProcessingConfiguration, EventProcessingConfigurer { protected static String packageOfObject(Object object) { return object.getClass().getName().replace("." + object.getClass().getSimpleName(), ""); }  }
EventProcessingModule implements ModuleConfiguration, EventProcessingConfiguration, EventProcessingConfigurer { protected static String packageOfObject(Object object) { return object.getClass().getName().replace("." + object.getClass().getSimpleName(), ""); }  @Override void initialize(Configuration configuration); @SuppressWarnings("unchecked") @Override Optional<T> eventProcessorByProcessingGroup(String processingGroup); @Override Map<String, EventProcessor> eventProcessors(); @Override String sagaProcessingGroup(Class<?> sagaType); @Override List<MessageHandlerInterceptor<? super EventMessage<?>>> interceptorsFor(String processorName); @Override ListenerInvocationErrorHandler listenerInvocationErrorHandler(String processingGroup); @Override SequencingPolicy<? super EventMessage<?>> sequencingPolicy(String processingGroup); @Override RollbackConfiguration rollbackConfiguration(String componentName); @Override ErrorHandler errorHandler(String componentName); @Override SagaStore sagaStore(); @Override List<SagaConfiguration<?>> sagaConfigurations(); @Override MessageMonitor<? super Message<?>> messageMonitor(Class<?> componentType,
                                                             String eventProcessorName); @Override TokenStore tokenStore(String processorName); @Override TransactionManager transactionManager(String processingGroup); @Override EventProcessingConfigurer registerSaga(Class<T> sagaType, Consumer<SagaConfigurer<T>> sagaConfigurer); @Override EventProcessingConfigurer registerSagaStore(
            Function<Configuration, SagaStore> sagaStoreBuilder); @Override EventProcessingConfigurer registerEventHandler(
            Function<Configuration, Object> eventHandlerBuilder); @Override EventProcessingConfigurer registerDefaultListenerInvocationErrorHandler(
            Function<Configuration, ListenerInvocationErrorHandler> listenerInvocationErrorHandlerBuilder); @Override EventProcessingConfigurer registerListenerInvocationErrorHandler(String processingGroup,
                                                                            Function<Configuration, ListenerInvocationErrorHandler> listenerInvocationErrorHandlerBuilder); @Override EventProcessingConfigurer configureDefaultStreamableMessageSource(Function<Configuration, StreamableMessageSource<TrackedEventMessage<?>>> defaultSource); @Override EventProcessingConfigurer configureDefaultSubscribableMessageSource(Function<Configuration, SubscribableMessageSource<EventMessage<?>>> defaultSource); @Override EventProcessingConfigurer registerTrackingEventProcessor(String name,
                                                                    Function<Configuration, StreamableMessageSource<TrackedEventMessage<?>>> source); @Override EventProcessingConfigurer registerTrackingEventProcessor(String name,
                                                                    Function<Configuration, StreamableMessageSource<TrackedEventMessage<?>>> source,
                                                                    Function<Configuration, TrackingEventProcessorConfiguration> processorConfiguration); @Override EventProcessingConfigurer registerEventProcessorFactory(
            EventProcessorBuilder eventProcessorBuilder); @Override EventProcessingConfigurer registerEventProcessor(String name,
                                                            EventProcessorBuilder eventProcessorBuilder); @Override EventProcessingConfigurer registerTokenStore(String processingGroup,
                                                        Function<Configuration, TokenStore> tokenStore); @Override EventProcessingConfigurer registerTokenStore(Function<Configuration, TokenStore> tokenStore); @Override EventProcessingConfigurer usingSubscribingEventProcessors(); @Override EventProcessingConfigurer usingTrackingEventProcessors(); @Override EventProcessingConfigurer registerSubscribingEventProcessor(String name,
                                                                       Function<Configuration, SubscribableMessageSource<? extends EventMessage<?>>> messageSource); @Override EventProcessingConfigurer registerDefaultErrorHandler(
            Function<Configuration, ErrorHandler> errorHandlerBuilder); @Override EventProcessingConfigurer registerErrorHandler(String eventProcessorName,
                                                          Function<Configuration, ErrorHandler> errorHandlerBuilder); @Override EventProcessingConfigurer byDefaultAssignHandlerInstancesTo(Function<Object, String> assignmentFunction); @Override EventProcessingConfigurer byDefaultAssignHandlerTypesTo(Function<Class<?>, String> assignmentFunction); @Override EventProcessingConfigurer assignHandlerInstancesMatching(String processingGroup, int priority,
                                                                    Predicate<Object> criteria); @Override EventProcessingConfigurer assignHandlerTypesMatching(String processingGroup, int priority,
                                                                Predicate<Class<?>> criteria); @Override EventProcessingConfigurer assignProcessingGroup(String processingGroup, String processorName); @Override EventProcessingConfigurer assignProcessingGroup(Function<String, String> assignmentRule); @Override EventProcessingConfigurer registerHandlerInterceptor(String processorName,
                                                                Function<Configuration, MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder); @Override EventProcessingConfigurer registerDefaultHandlerInterceptor(
            BiFunction<Configuration, String, MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder); @Override EventProcessingConfigurer registerSequencingPolicy(String processingGroup,
                                                              Function<Configuration, SequencingPolicy<? super EventMessage<?>>> policyBuilder); @Override EventProcessingConfigurer registerDefaultSequencingPolicy(
            Function<Configuration, SequencingPolicy<? super EventMessage<?>>> policyBuilder); @Override EventProcessingConfigurer registerMessageMonitorFactory(String eventProcessorName,
                                                                   MessageMonitorFactory messageMonitorFactory); @Override EventProcessingConfigurer registerRollbackConfiguration(String name,
                                                                   Function<Configuration, RollbackConfiguration> rollbackConfigurationBuilder); @Override EventProcessingConfigurer registerTransactionManager(String name,
                                                                Function<Configuration, TransactionManager> transactionManagerBuilder); @Override EventProcessingConfigurer registerTrackingEventProcessorConfiguration(
            Function<Configuration, TrackingEventProcessorConfiguration> trackingEventProcessorConfigurationBuilder); }
EventProcessingModule implements ModuleConfiguration, EventProcessingConfiguration, EventProcessingConfigurer { protected static String packageOfObject(Object object) { return object.getClass().getName().replace("." + object.getClass().getSimpleName(), ""); }  @Override void initialize(Configuration configuration); @SuppressWarnings("unchecked") @Override Optional<T> eventProcessorByProcessingGroup(String processingGroup); @Override Map<String, EventProcessor> eventProcessors(); @Override String sagaProcessingGroup(Class<?> sagaType); @Override List<MessageHandlerInterceptor<? super EventMessage<?>>> interceptorsFor(String processorName); @Override ListenerInvocationErrorHandler listenerInvocationErrorHandler(String processingGroup); @Override SequencingPolicy<? super EventMessage<?>> sequencingPolicy(String processingGroup); @Override RollbackConfiguration rollbackConfiguration(String componentName); @Override ErrorHandler errorHandler(String componentName); @Override SagaStore sagaStore(); @Override List<SagaConfiguration<?>> sagaConfigurations(); @Override MessageMonitor<? super Message<?>> messageMonitor(Class<?> componentType,
                                                             String eventProcessorName); @Override TokenStore tokenStore(String processorName); @Override TransactionManager transactionManager(String processingGroup); @Override EventProcessingConfigurer registerSaga(Class<T> sagaType, Consumer<SagaConfigurer<T>> sagaConfigurer); @Override EventProcessingConfigurer registerSagaStore(
            Function<Configuration, SagaStore> sagaStoreBuilder); @Override EventProcessingConfigurer registerEventHandler(
            Function<Configuration, Object> eventHandlerBuilder); @Override EventProcessingConfigurer registerDefaultListenerInvocationErrorHandler(
            Function<Configuration, ListenerInvocationErrorHandler> listenerInvocationErrorHandlerBuilder); @Override EventProcessingConfigurer registerListenerInvocationErrorHandler(String processingGroup,
                                                                            Function<Configuration, ListenerInvocationErrorHandler> listenerInvocationErrorHandlerBuilder); @Override EventProcessingConfigurer configureDefaultStreamableMessageSource(Function<Configuration, StreamableMessageSource<TrackedEventMessage<?>>> defaultSource); @Override EventProcessingConfigurer configureDefaultSubscribableMessageSource(Function<Configuration, SubscribableMessageSource<EventMessage<?>>> defaultSource); @Override EventProcessingConfigurer registerTrackingEventProcessor(String name,
                                                                    Function<Configuration, StreamableMessageSource<TrackedEventMessage<?>>> source); @Override EventProcessingConfigurer registerTrackingEventProcessor(String name,
                                                                    Function<Configuration, StreamableMessageSource<TrackedEventMessage<?>>> source,
                                                                    Function<Configuration, TrackingEventProcessorConfiguration> processorConfiguration); @Override EventProcessingConfigurer registerEventProcessorFactory(
            EventProcessorBuilder eventProcessorBuilder); @Override EventProcessingConfigurer registerEventProcessor(String name,
                                                            EventProcessorBuilder eventProcessorBuilder); @Override EventProcessingConfigurer registerTokenStore(String processingGroup,
                                                        Function<Configuration, TokenStore> tokenStore); @Override EventProcessingConfigurer registerTokenStore(Function<Configuration, TokenStore> tokenStore); @Override EventProcessingConfigurer usingSubscribingEventProcessors(); @Override EventProcessingConfigurer usingTrackingEventProcessors(); @Override EventProcessingConfigurer registerSubscribingEventProcessor(String name,
                                                                       Function<Configuration, SubscribableMessageSource<? extends EventMessage<?>>> messageSource); @Override EventProcessingConfigurer registerDefaultErrorHandler(
            Function<Configuration, ErrorHandler> errorHandlerBuilder); @Override EventProcessingConfigurer registerErrorHandler(String eventProcessorName,
                                                          Function<Configuration, ErrorHandler> errorHandlerBuilder); @Override EventProcessingConfigurer byDefaultAssignHandlerInstancesTo(Function<Object, String> assignmentFunction); @Override EventProcessingConfigurer byDefaultAssignHandlerTypesTo(Function<Class<?>, String> assignmentFunction); @Override EventProcessingConfigurer assignHandlerInstancesMatching(String processingGroup, int priority,
                                                                    Predicate<Object> criteria); @Override EventProcessingConfigurer assignHandlerTypesMatching(String processingGroup, int priority,
                                                                Predicate<Class<?>> criteria); @Override EventProcessingConfigurer assignProcessingGroup(String processingGroup, String processorName); @Override EventProcessingConfigurer assignProcessingGroup(Function<String, String> assignmentRule); @Override EventProcessingConfigurer registerHandlerInterceptor(String processorName,
                                                                Function<Configuration, MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder); @Override EventProcessingConfigurer registerDefaultHandlerInterceptor(
            BiFunction<Configuration, String, MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder); @Override EventProcessingConfigurer registerSequencingPolicy(String processingGroup,
                                                              Function<Configuration, SequencingPolicy<? super EventMessage<?>>> policyBuilder); @Override EventProcessingConfigurer registerDefaultSequencingPolicy(
            Function<Configuration, SequencingPolicy<? super EventMessage<?>>> policyBuilder); @Override EventProcessingConfigurer registerMessageMonitorFactory(String eventProcessorName,
                                                                   MessageMonitorFactory messageMonitorFactory); @Override EventProcessingConfigurer registerRollbackConfiguration(String name,
                                                                   Function<Configuration, RollbackConfiguration> rollbackConfigurationBuilder); @Override EventProcessingConfigurer registerTransactionManager(String name,
                                                                Function<Configuration, TransactionManager> transactionManagerBuilder); @Override EventProcessingConfigurer registerTrackingEventProcessorConfiguration(
            Function<Configuration, TrackingEventProcessorConfiguration> trackingEventProcessorConfigurationBuilder);  }