private void drainMessagesQueue() {
		while (true) {
			try {
				postDrainedMessages(messagesQueue.take());
			} catch (InterruptedException ex) {
				List<List<String>> drainedMessages = new ArrayList<>();
				messagesQueue.drainTo(drainedMessages);
				drainedMessages.forEach(this::postDrainedMessages);
				break;
			}
		}
	}

	private void drainMessagesQueue() {
		try {
			while (true) {
				postDrainedMessages(messagesQueue.take());
			}
		} catch (InterruptedException ex) {
			List<List<String>> drainedMessages = new ArrayList<>();
			messagesQueue.drainTo(drainedMessages);
			drainedMessages.forEach(this::postDrainedMessages);
			Thread.currentThread().interrupt();
		}
	}