Package | Description |
---|---|
org.glassfish.grizzly.comet | |
org.glassfish.grizzly.comet.concurrent |
Modifier and Type | Class and Description |
---|---|
class |
DefaultCometHandler<E>
A basic default implementation of CometHandler to take care of tracking the Response and CometContext.
|
Modifier and Type | Method and Description |
---|---|
List<CometHandler> |
CometContext.getCometHandlers()
Return the current list of active
CometHandler |
Modifier and Type | Method and Description |
---|---|
int |
CometContext.addCometHandler(CometHandler<E> handler)
Add a
CometHandler . |
protected void |
CometContext.initialize(CometHandler handler)
Initialize the newly added
CometHandler . |
boolean |
CometContext.interrupt(CometHandler handler,
boolean finishExecution)
Interrupt a
CometHandler by invoking onInterrupt(org.glassfish.grizzly.comet.CometEvent) |
protected boolean |
CometEngine.interrupt(CometHandler handler,
boolean finishExecution)
Deprecated.
use the CometContext version
|
protected void |
CometContext.interrupt0(CometHandler handler,
boolean finishExecution)
Interrupt logic in its own method, so it can be executed either async or sync.
cometHandler.onInterrupt is performed async due to its functionality is unknown, hence not safe to run in the performance critical selector thread. |
protected void |
CometEngine.interrupt0(CometHandler handler,
boolean finishExecution)
Deprecated.
use the CometContext version
|
protected void |
CometContext.invokeCometHandler(CometEvent event,
CometHandler cometHandler)
Invoke a
CometHandler using the CometEvent |
boolean |
CometContext.isActive(CometHandler handler)
Return true if this
CometHandler is still active, e.g. |
void |
DefaultNotificationHandler.notify(CometEvent cometEvent,
CometHandler cometHandler)
Notify the
CometHandler . |
void |
NotificationHandler.notify(CometEvent cometEvent,
CometHandler cometHandler)
Notify a single
CometHandler . |
void |
CometContext.notify(E attachment,
CometEvent.Type eventType,
CometHandler cometHandler)
Notify a single
CometHandler . |
void |
CometContext.notify(E attachment,
CometHandler cometHandler)
Notify a single
onEvent(CometEvent) . |
protected void |
DefaultNotificationHandler.notify0(CometEvent cometEvent,
CometHandler cometHandler)
Notify a
CometHandler . |
boolean |
CometContext.removeCometHandler(CometHandler handler)
Remove a
CometHandler . |
boolean |
CometContext.removeCometHandler(CometHandler handler,
boolean resume)
Remove a
CometHandler . |
boolean |
CometContext.resumeCometHandler(CometHandler handler)
Resume the Comet request and remove it from the active
CometHandler list. |
Modifier and Type | Method and Description |
---|---|
void |
DefaultNotificationHandler.notify(CometEvent cometEvent,
Iterator<CometHandler> iteratorHandlers)
Notify all
CometHandler . |
void |
NotificationHandler.notify(CometEvent cometEvent,
Iterator<CometHandler> iteratorHandlers)
Notify all
CometHandler . |
Modifier and Type | Class and Description |
---|---|
class |
DefaultConcurrentCometHandler<E>
We queue events in each CometHandler to lower the probability that slow or massive IO for one CometHandler severely
delays events to others.
only streaming mode can benefit from buffering messages like this. |
Copyright © 2014 Oracle Corporation. All rights reserved.