code: ThreadPoolExecutor createChannelExecutor(String channel, final String threadPrefix, final int workerCount, int queueSize) {
  		ThreadFactory threadFactory = new ThreadFactory() {
  			private int counter = 0;
  			@Override
  			public Thread newThread(Runnable runnable) {
  				return new Thread(runnable, threadPrefix + "-" + ++counter);
  			}
  		};
  		ThreadPoolExecutor executor = new ChannelThreadPoolExecutor(channel, workerCount,
  				new LinkedBlockingQueue<Runnable>(queueSize), threadFactory);
  		return executor;
  	}
docs: create ThreadPoolExecutor for channel