Package | Description |
---|---|
org.glassfish.grizzly.comet | |
org.glassfish.grizzly.comet.concurrent |
Modifier and Type | Field and Description |
---|---|
protected CometEvent<CometContext> |
CometContext.eventInterrupt |
protected CometEvent<CometContext> |
CometContext.eventTerminate |
Modifier and Type | Method and Description |
---|---|
protected void |
CometContext.invokeCometHandler(CometEvent event,
CometHandler cometHandler)
Invoke a
CometHandler using the CometEvent |
void |
DefaultNotificationHandler.notify(CometEvent cometEvent,
CometHandler cometHandler)
Notify the
CometHandler . |
void |
NotificationHandler.notify(CometEvent cometEvent,
CometHandler cometHandler)
Notify a single
CometHandler . |
void |
DefaultNotificationHandler.notify(CometEvent cometEvent,
Iterator<CometHandler> iteratorHandlers)
Notify all
CometHandler . |
void |
NotificationHandler.notify(CometEvent cometEvent,
Iterator<CometHandler> iteratorHandlers)
Notify all
CometHandler . |
protected void |
DefaultNotificationHandler.notify0(CometEvent cometEvent,
CometHandler cometHandler)
Notify a
CometHandler . |
void |
DefaultCometHandler.onEvent(CometEvent event) |
void |
CometHandler.onEvent(CometEvent event)
Receive
CometEvent notification. |
void |
DefaultCometHandler.onInitialize(CometEvent event) |
void |
CometHandler.onInitialize(CometEvent event)
Receive
CometEvent notification when Grizzly is about to suspend the connection. |
void |
DefaultCometHandler.onInterrupt(CometEvent event) |
void |
CometHandler.onInterrupt(CometEvent event)
Receive
CometEvent notification when the underlying tcp communication is resumed by Grizzly. |
void |
DefaultCometHandler.onTerminate(CometEvent event) |
void |
CometHandler.onTerminate(CometEvent event)
Receive
CometEvent notification when the response is resumed by a CometHandler or by the CometContext |
Modifier and Type | Field and Description |
---|---|
protected Queue<CometEvent> |
DefaultConcurrentCometHandler.messageQueue
todo replace with non array copying list for non resizing add situations, using internal index to keep track of
state , not a linked list, it has too much overhead and eats memory.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultConcurrentCometHandler.enqueueEvent(CometEvent event)
Queues event if another thread is currently working on this handler.
|
void |
DefaultConcurrentCometHandler.onInterrupt(CometEvent event)
Receive
CometEvent notification when the underlying tcp communication is resumed by Grizzly. |
void |
DefaultConcurrentCometHandler.onQueueFull(CometEvent event)
Called in synchronized context when the comet handler's local event queue is full.
default impl resumes the comet handler |
void |
DefaultConcurrentCometHandler.onTerminate(CometEvent event)
Receive
CometEvent notification when the response is resumed by a CometHandler or by the CometContext |
Copyright © 2014 Oracle Corporation. All rights reserved.