@Override
	protected void doStop() {
		this.running.set(false);
		this.taskExecutor.getThreadPoolExecutor().shutdownNow();
		try {
			if (!this.taskExecutor.getThreadPoolExecutor().awaitTermination(10, TimeUnit.SECONDS)) {
				logger.error("Reader task failed to stop");
			}
		}
		catch (InterruptedException e) {
			Thread.currentThread().interrupt();
		}
	}
Filter tweets by language or languages.
extensions/spring-xd-extension-twitter/src/main/java/org/springframework/integration/x/twitter/AbstractTwitterInboundChannelAdapter.java