public class StateNotifier extends HttpServlet {
	private static final long serialVersionUID = 1L;
	
	private ServerMessage<String> serverMessage =null;
	private ByteArrayOutputStream baos = null;
	private ObjectOutputStream oos = null;
	
	@Override
	public void init() throws ServletException {
		super.init();
		try {
			baos=new ByteArrayOutputStream();
			oos=new ObjectOutputStream(baos);
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	@Override
	public void service(ServletRequest arg0, ServletResponse response) throws ServletException, IOException {
		ServletOutputStream out = response.getOutputStream();

//		String head = "HTTP/1.0 200 OK\n" + "Server: VoltmeterServlet\n"
//				+ "Content-Type: text/html; charset=utf-8\n"
//				+ "Connection: Keep-Alive\n"
//				+ "Content-Encoding: multipart/mixed\n"
//				+ "Transfer-Encoding: chunked" + "Pragma: no-cache\n\n";
//		
//		oos.writeObject(head);
//		out.write(baos.toByteArray());
//		
//		baos.reset();
		
		try {
			while (true) {
				serverMessage = new ServerMessage<String>("my serverMessage ["+(System.currentTimeMillis()/1000)+"]");
				System.out.println(serverMessage.getEntity());
				
				oos.writeObject(serverMessage);
				out.write(baos.toByteArray());
				out.flush();
				baos.reset();
				
				Thread.currentThread().sleep(3000);
			}
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
}

	private class ServerStateNotifierRunnable implements Runnable{
		
		@Override
		public void run() {
			
			HttpURLConnection connection = null;
			try {
				String urlParameters = "smth=9";
				
				URL url = new URL(homeUrl+"/StateNotifier");
				connection=(HttpURLConnection) url.openConnection();
				connection.setRequestMethod("POST");
				connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
				
				connection.setRequestProperty("Content-Length", "" +  Integer.toString(urlParameters.getBytes().length));
				connection.setRequestProperty("Content-Language", charset);  
				
				connection.setUseCaches (false);
				connection.setDoInput(true);
				connection.setDoOutput(true);
				
				//Send request
				DataOutputStream wr = new DataOutputStream (connection.getOutputStream ());
				wr.writeBytes (urlParameters);
				wr.flush ();
				wr.close ();
				
				//Get Response
				ObjectInputStream ois= new ObjectInputStream(connection.getInputStream());
				Object response;

				try {
					while(true){
						
						response = ois.readObject();
						
						if(response instanceof ServerMessage){
							if(((ServerMessage<?>)response).getMessageType().equals(ServerMessageType.ERROR)){
								ServerMessage<Exception> errMessage=(ServerMessage<Exception>) response;
								JOptionPane.showMessageDialog(PRMModellerGUI.this.parent, errMessage.getEntity().getMessage(), resourceBundle.getString("layout.policy.changed.error.title"), JOptionPane.ERROR_MESSAGE);
								return ;
							}
							ServerMessage<String> theServerMessage = (ServerMessage<String>)response;
							System.out.println(theServerMessage.getEntity());
							
						}else{
//							JOptionPane.showMessageDialog(parent, "Unknown responce [load processing list]", resourceBundle.getString("layout.policy.changed.error.title"), JOptionPane.ERROR_MESSAGE);
//							return ;
							System.out.println("somthing wrong");
						}
						
						try {
							if(ois.available() >0 ){
								continue;
							}else{
								Thread.currentThread().sleep(100);
							}
						} catch (InterruptedException e) {
							e.printStackTrace();
						}
						
					}
				} catch (ClassNotFoundException cnfe) {
					logger.log(Level.WARNING, cnfe.getLocalizedMessage(), cnfe);
				}
				
			} catch (IOException ioe) {
				logger.log(Level.WARNING, ioe.getLocalizedMessage(), ioe);
			}finally{
				if(connection != null){
					connection.disconnect();
				}
				
			}
			
			
		}
		
	}