@Override
	public void run()
	{
		Client.INSTANCE.start();

		for (int cnt = 0; cnt < this.total_requests; cnt++)
		{
			IPMessage msg;
			try
			{
				msg = this.request_queue.take();

				if (msg instanceof UpdateMessage)	// issue an update request
					Client.INSTANCE.issueUpdateRequest((UpdateMessage) msg);
				else	// issue a query request
					Client.INSTANCE.issueQueryRequest((QueryMessage) msg);

			} catch (InterruptedException ie)
			{
				ie.printStackTrace();
			}
		}
	}