@Override
	public void run() {
		this.queue.start();
		
		PartialMessage str = null;
		while (null != (str = this.socketAdapter.read(str))) {
			if (str.isComplete()) {
				this.handleMessage(this.parseMessage(str.getMessage()));
				str = null;
			}
		}
	}