Ajaxion - Standalone AJAX - Part 2 of 2 - C# and Java Example

package pw.ajaxion;

import java.io.IOException;
import java.io.PrintWriter;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import pw.log.FileLog;


public final class AjaxionEventConsumer
{
	private String URL_EVENT = "e";
	private String URL_PARAM = "p";
	//private String URL_DATE = "d";

	public AjaxionEventConsumer(HttpServletRequest request, 
										 HttpServletResponse response)
										 throws Exception
	{
		init(request, response, 0);
	}

	public AjaxionEventConsumer(HttpServletRequest request, 
										 HttpServletResponse response, long sleep)
										 throws Exception
	{
		init(request, response, sleep);
	}

	private HttpServletResponse response;
	private PrintWriter responsePrinter;

	public String getEventId()
	{
		return eventId;
	}
	private String eventId;

	public String getParameters()
	{
		return param;
	}
	private String param;

	public void init(HttpServletRequest request, HttpServletResponse response, long sleep)
		throws Exception
	{
		try
		{
			this.response = response;
			eventId = request.getParameter(URL_EVENT);

			param = request.getParameter(URL_PARAM);
			if (param == null)
				param = "";

			if (sleep > 0)
				Thread.sleep(sleep);
		}
		catch (Exception ex)
		{						 
		   String message = "AjaxionEventHandler.init exception : " + ex.getMessage();
		   FileLog.WriteLn(new FileLog().getFileName(), message);
		   throw new Exception(message);
		}
	}

	public void init(HttpServletRequest request, HttpServletResponse response)
		throws Exception
	{
		init(request, response, 0);
	}
	
	public void consumeEvent(String responseData, String responseContentType)
		throws Exception
	{
		beginResponse(responseContentType);
		responsePrinter.print(responseData);
		endResponse();
	}
	public void consumeEvent(byte[] responseData, String responseContentType)
		throws Exception
	{
		beginResponse(responseContentType);
		responsePrinter.print(responseData);
		endResponse();
	}

	public void beginResponse(String contentType)
		throws IOException
	{
	   if (responsePrinter == null)
	      responsePrinter = response.getWriter();

	   response.setContentType(contentType);
	   responsePrinter.flush();
	}
	public void respondString(String responseData)
		throws Exception
	{
	   if (response.getContentType().indexOf("text") > -1)
	   {
	      responsePrinter.print(responseData);
	      responsePrinter.flush();
	   }
	   else
	      throw new Exception("Unexpected content type...");
	}
	public void respondBytes(byte[] responseData)
		throws Exception
	{
		if (response.getContentType().indexOf("text") == -1)
		{
		   responsePrinter. print(responseData);
		   responsePrinter.flush();
		}
		else
			throw new Exception("Unexpected content type...");
	}

	public void endResponse() throws Exception
	{
		try
		{
			if (responsePrinter != null)
			{
				responsePrinter.flush();
				responsePrinter.close();
				responsePrinter = null;
			}
		}
		catch (Exception ex)
		{
		   String message = "AjaxionEventHandler.endResponse exception : " + ex.getMessage();
		   FileLog.WriteLn(new FileLog().getFileName(), message);
		   throw new Exception(message);
		}
	}
}