extracted out forking to utility class
created simple clustered event bus
refactored the reading/writing bytes to separate methods
added spring helper classes to allow declarative usage of events and cluster limiting