@Override
	public void run() {
		while(true) {
			/*
			 * Get a tweet from the queue and process it
			 */
			try {
				Tweet msg = this.messagesToConsume.take();
				consumer.consume(msg);
			} catch (InterruptedException e) {
				
			}
		}
	}