private void consume() {
		try {
			if (requestSocket != null) {		
				while (!queue.isEmpty()) {
					for (ProcessRequestData processRequestData : queue) {
						queue.poll();
						processCommand.processRequest(processRequestData);					
					}
					queue.notifyAll();
				}
			} else {
				Thread.sleep(wait);
				ComvenientConsumer.getConnection();
			}
		} catch (InterruptedException e) {
			logger.error("thread is Interrupted for the : " + e.getCause().getLocalizedMessage());
		}

	}