private void notifyNewPrimary() {

			// Notify discovery server
			try {
				Socket notifySocket = new Socket(discovery_ipAddrs,
						discovery_portNum);
				BufferedWriter wr = new BufferedWriter(new OutputStreamWriter(
						notifySocket.getOutputStream()));

				String path = "/notifyNewPrimary";
				wr.write("POST " + path + " HTTP/1.1\r\n");
				wr.write("\r\n");
				wr.write(currentPrimary.toString());
				wr.flush();
				wr.close();
				notifySocket.close();
			} catch (IOException e) {
				logger.debug(e.getMessage(), e);
			}

			// Notify all secondary servers
			for (int i = 0; i < backEndsArray.size(); i++) {
				JSONObject eachBackEnd = (JSONObject) backEndsArray.get(i);
				int each_dateserverID = Integer.valueOf(eachBackEnd.get(
						"dataserverID").toString());
				String eachBackEnd_ipAddrs = eachBackEnd.get("ipAddrs")
						.toString();
				int eachBackEnd_portNum = Integer.valueOf(eachBackEnd.get(
						"portNum").toString());
				if (each_dateserverID != dataserverID) {
					try {
						Socket notifySocket = new Socket(eachBackEnd_ipAddrs,
								eachBackEnd_portNum);

						BufferedWriter wr = new BufferedWriter(
								new OutputStreamWriter(
										notifySocket.getOutputStream()));

						String path = "/notifyNewPrimary";
						wr.write("POST " + path + " HTTP/1.1\r\n");
						wr.write("\r\n");
						wr.write(currentPrimary.toString());
						wr.flush();
						wr.close();
						notifySocket.close();
					} catch (IOException e) {
						logger.debug(e.getMessage(), e);
					}
				}
			}
		}