cometstate.java

RESIN 3.2 最新源码

package example;

import com.caucho.servlet.comet.*;

public class CometState {
  private final CometController _controller;

  private int _count;

  public CometState(CometController controller)
  {
    _controller = controller;
  }

  public boolean isClosed()
  {
    return _controller.isClosed();
  }

  public boolean wake()
  {
    _controller.setAttribute("comet.count", ++_count);

    if (_count <= 10) {
      _controller.wake();
    
      return ! _controller.isClosed();
    }
    else {
      _controller.close();

      return false;
    }
  }
}