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

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;

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

import nl.justobjects.pushlet.core.Dispatcher;
import nl.justobjects.pushlet.core.Event;
import nl.justobjects.pushlet.core.SessionManager;

public class ChatServlet extends HttpServlet {
	private static final long serialVersionUID = 1L;

	public ChatServlet() {
		super();
	}

	protected void service(HttpServletRequest request,
			HttpServletResponse response) throws ServletException, IOException {
		// myUnicast();
		myBroadcast();
		// myBroadcast();
		request.getRequestDispatcher("send.jsp").forward(request, response);
	}

	//指定用户发送
	private void myMulticast() {
		Event event = Event.createDataEvent("/chat");
		// Event event = Event.createDataEvent("/guoguo");
		event.setField("hw", "Multicast msg");
		Dispatcher.getInstance().unicast(event, "piero"); // 向所有和myevent1名称匹配的事件推送

		System.out.println("wa success....");

	}

	private void myBroadcast() {
		Event event = Event.createDataEvent("/chat"); // 向所有的事件推送，不要求和这儿的myevent1名称匹配
		event.setField("hw", "Broadcast msg");
		Dispatcher.getInstance().broadcast(event);

		System.out.println("asw success....");
	}

}