public static <E> TopicProcessor<E> create(String name, int bufferSize) {
		return TopicProcessor.<E>builder().name(name).bufferSize(bufferSize).build();
	}
public static <E> TopicProcessor<E> create(String name, int bufferSize) {
		return TopicProcessor.<E>builder().name(name).bufferSize(bufferSize).build();
	}
public static < E > TopicProcessor < E > create ( String name , int bufferSize ) { return TopicProcessor . < E > builder ( ) . name ( name ) . bufferSize ( bufferSize ) . build ( ) ; }
Create a new TopicProcessor using the provided backlog size, with a blockingWait Strategy
and auto-cancellation. <p> A new Cached ThreadExecutorPool will be implicitly created and will use the passed name to
qualify the created threads.
@param name Use a new Cached ExecutorService and assign this name to the created
threads
@param bufferSize A Backlog Size to mitigate slow subscribers
@param <E> Type of processed signals
@return the fresh TopicProcessor instance
Create a new TopicProcessor using the provided backlog size with a blockingWait Strategy and auto - cancellation . <p > A new Cached ThreadExecutorPool will be implicitly created and will use the passed name to qualify the created threads .