Axon TrackingEventProcessor example

trackedproj.java

@Configuration
public class ProjectionsConfiguration {
	@Autowired
	private EventHandlingConfiguration eventHandlingConfiguration;

	@Autowired
	private EventStorageEngine eventStorageEngine;

	@PostConstruct
	public void startTrackingProjections() throws ClassNotFoundException {
		ClassPathScanningCandidateComponentProvider scanner = new ClassPathScanningCandidateComponentProvider(false);
		scanner.addIncludeFilter(new AnnotationTypeFilter(TrackedProjection.class));
		for (BeanDefinition bd : scanner.findCandidateComponents("org.demo")) {
			Class<?> aClass = Class.forName(bd.getBeanClassName());
			ProcessingGroup processingGroup = aClass.getAnnotation(ProcessingGroup.class);
			String name = Optional.ofNullable(processingGroup).map(ProcessingGroup::value).orElse(aClass.getPackage().getName());
			registerTrackingProcessor(name);
		}
	}

	private void registerTrackingProcessor(String name) {
		eventHandlingConfiguration.registerTrackingProcessor(name);
	}
}


@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
public @interface TrackedProjection {
}