Sorry, forgot to check this with GF, so the line I've mentioned is
required anyway, but let me check if the sample properly works in GF.
WBR,
Alexey.
On Jul 13, 2010, at 14:44 , Oleksiy Stashok wrote:
> Hi,
>
> you need to resume the CometHandler in the onEvent method like:
>
> public void onEvent(CometEvent event) throws IOException
> {
> if (CometEvent.NOTIFY == event.getType())
> {
> PrintWriter writer = response.getWriter();
> writer.write((String)event.attachment());
> writer.flush();
>
> ---> event.getCometContext().resumeCometHandler(this);
>
> }
> }
>
>
> WBR,
> Alexey.
>
> On Jul 13, 2010, at 0:54 , lockekal1965_at_aol.com wrote:
>
>> I am trying to get a simple Comet example working that I took from http://blogs.sun.com/msreddy/entry/how_to_make_grizzly_comet
>> .
>>
>> The issue is onEvent() never gets invoked. I have verified this by
>> tracing through my code in NetBeans. I have verified that my comet
>> server is
>> running, I can receive the requests from my browser, the comet
>> handler is added and notify is invoked. But I get no response back
>> from the server.
>> I am running NB 6.8, GF v3
>>
>> Any ideas ?
>>
>> My code is as follows:
>> public class MyCometServlet extends HttpServlet
>> {
>>
>> private class CometMsgHandler implements
>> CometHandler<HttpServletResponse>
>> {
>>
>> private HttpServletResponse response;
>>
>> public void onEvent(CometEvent event) throws IOException
>> {
>> if (CometEvent.NOTIFY == event.getType())
>> {
>> PrintWriter writer = response.getWriter();
>> writer.write((String)event.attachment());
>> writer.flush();
>> }
>> }
>>
>> public void onInitialize(CometEvent event) throws IOException
>> {
>> }
>>
>> public void onInterrupt(CometEvent event) throws IOException
>> {
>> removeThisFromContext();
>> }
>>
>> public void onTerminate(CometEvent event) throws IOException
>> {
>> removeThisFromContext();
>> }
>>
>> public void attach(HttpServletResponse attachment)
>> {
>> this.response = attachment;
>> }
>>
>> private void removeThisFromContext() throws IOException
>> {
>> response.getWriter().close();
>> }
>> }
>>
>> private static final long serialVersionUID = 1L;
>>
>> @Override
>> public void init(ServletConfig config) throws ServletException {
>> }
>>
>> @Override
>> protected void doGet(HttpServletRequest req,
>> HttpServletResponse res) throws ServletException, IOException
>> {
>> doPost(req, res);
>> }
>>
>> @Override
>> protected void doPost(HttpServletRequest req,
>> HttpServletResponse res) throws ServletException, IOException
>> {
>> String contextPath = req.getParameter("client");
>> String message = req.getParameter("message");
>>
>> CometEngine engine = CometEngine.getEngine();
>> if (message == null)
>> {
>> if (contextPath != null)
>> {
>> CometContext cc = engine.getCometContext(contextPath);
>> if (cc == null)
>> {
>> cc = engine.register(contextPath);
>> cc.setExpirationDelay(60000); // how long to
>> hold client
>> CometMsgHandler handler = new CometMsgHandler();
>> handler.attach(res);
>> cc.addCometHandler(handler); //suspend connection
>> cc.notify("init ..."); //all suspended
>> connections are are invoked.
>> }
>> }
>> }
>> else
>> {
>> CometContext cc = engine.getCometContext(contextPath);
>> if (cc != null)
>> {
>> cc.notify(message);
>> }
>> }
>> }
>> }
>