|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.sun.grizzly.cometd.DataHandler
public class DataHandler
CometHandler used to support the meta channel Verb Connect and Reconnect. The DataHandler is holding the state of the long polled (Comet) connection.
Constructor Summary | |
---|---|
DataHandler(String clientId,
BayeuxParser bayeuxParser)
|
Method Summary | |
---|---|
void |
addChannel(String channel)
|
void |
attach(Object[] reqRes)
Attach an intance of E to this class. |
boolean |
containsChannel(String channel)
|
Collection<String> |
getChannels()
|
String |
getClientId()
|
int |
getRemotePort()
|
boolean |
isSuspended()
|
void |
onEvent(CometEvent event)
Receive CometEvent notification. |
void |
onInitialize(CometEvent event)
Receive CometEvent notification when Grizzly is about to
suspend the connection. |
void |
onInterrupt(CometEvent event)
Receive CometEvent notification when the underlying
tcp communication is resumed by Grizzly. |
void |
onTerminate(CometEvent event)
Receive CometEvent notification when the response
is resumed by a CometHandler or by the CometContext |
boolean |
removeChannel(String channel)
|
void |
setSuspended(boolean isSuspended)
|
protected void |
write(String s,
CometdResponse res,
boolean flush)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public DataHandler(String clientId, BayeuxParser bayeuxParser)
Method Detail |
---|
protected void write(String s, CometdResponse res, boolean flush) throws IOException
IOException
public void attach(Object[] reqRes)
CometHandler
attach
in interface CometHandler<Object[]>
public void onEvent(CometEvent event) throws IOException
CometHandler
CometEvent
notification. This method will be invoked
everytime a CometContext.notify(java.lang.Object)
is invoked. The CometEvent
will contains the message that can be pushed back to the remote client,
cached or ignored. This method can also be used to resume a connection
once a notified by invoking CometContext.resumeCometHandler(com.sun.grizzly.comet.CometHandler)
.
onEvent
in interface CometHandler<Object[]>
IOException
public void onInitialize(CometEvent event) throws IOException
CometHandler
CometEvent
notification when Grizzly is about to
suspend the connection. This method is always invoked during the
processing of CometContext.addCometHandler(com.sun.grizzly.comet.CometHandler, boolean)
operations.
onInitialize
in interface CometHandler<Object[]>
IOException
public void onTerminate(CometEvent event) throws IOException
CometHandler
CometEvent
notification when the response
is resumed by a CometHandler
or by the CometContext
onTerminate
in interface CometHandler<Object[]>
IOException
public void onInterrupt(CometEvent event) throws IOException
CometHandler
CometEvent
notification when the underlying
tcp communication is resumed by Grizzly. This happens
when the CometContext.setExpirationDelay(long)
expires or when
the remote client close the connection.
onInterrupt
in interface CometHandler<Object[]>
IOException
public String getClientId()
public Collection<String> getChannels()
public void addChannel(String channel)
public boolean containsChannel(String channel)
public boolean removeChannel(String channel)
public boolean isSuspended()
public void setSuspended(boolean isSuspended)
public int getRemotePort()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |