BackendReplicationRequestHandler.java

import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.util.Locale;

import org.apache.http.HttpException;
import org.apache.http.HttpRequest;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.MethodNotSupportedException;
import org.apache.http.entity.ContentProducer;
import org.apache.http.entity.EntityTemplate;
import org.apache.http.protocol.HttpContext;
import org.apache.http.protocol.HttpRequestHandler;

import com.google.gson.Gson;

public class BackendReplicationRequestHandler implements HttpRequestHandler {
	private static Gson g = new Gson();

	public void handle(final HttpRequest request, final HttpResponse response,
			final HttpContext context) throws HttpException, IOException {

		String method = request.getRequestLine().getMethod()
				.toUpperCase(Locale.ENGLISH);

		System.out.println("Handling Data Query; Line = "
				+ request.getRequestLine());
		if (method.equals("GET")) {
			final String Content = g.toJson(BackendDataStorage.getInstance().getReplication(),
					JSONsnapshot.class);
			System.out.println("Backend JSON: " + Content);
			EntityTemplate body = new EntityTemplate(new ContentProducer() {
				public void writeTo(final OutputStream outstream)
						throws IOException {
					OutputStreamWriter writer = new OutputStreamWriter(
							outstream, "UTF-8");
					writer.write(Content);
					writer.write("\n");
					writer.flush();
				}
			});
			body.setContentType("application/json; charset=UTF-8");

			response.setStatusCode(HttpStatus.SC_OK);
			response.setEntity(body);

		} else {
			throw new MethodNotSupportedException(method
					+ " method not supported\n");
		}

	}
}