com.sun.grizzly.messagesbus
Class MessagesBusCometHandler

java.lang.Object
  com.sun.grizzly.messagesbus.MessagesBusCometHandler

All Implemented Interfaces:

CometHandler<HttpServletResponse>

public class MessagesBusCometHandler
extends Object
implements CometHandler<HttpServletResponse>

Grizzly Comet CometHandler which push data to all suspended connection managed by MessagesBus

Author:

Jeanfrancois Arcand

Constructor Summary

protected	MessagesBusCometHandler(CometContext cometContext) Create a new CometHandler associated with CometContext
protected	MessagesBusCometHandler(CometContext cometContext, MessagesBus.CometType cometType) Create a new CometHandler associated with CometContext, supported the MessagesBus#CometType.

Method Summary

void	attach(HttpServletResponse response) The HttpServletResponse used to push back data,
void	onEvent(CometEvent event) Invoked when a CometContext.notify(com.sun.grizzly.comet.CometEvent, int, java.nio.channels.SelectionKey) is executing a push.
void	onInitialize(CometEvent event) Not used.
void	onInterrupt(CometEvent event) Invoked when MessagesBus.expirationDelay value expire.
void	onTerminate(CometEvent event) Never invoked as Grizly Comet CometContext API aren't exposed.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MessagesBusCometHandler

protected MessagesBusCometHandler(CometContext cometContext)

Create a new CometHandler associated with CometContext

Parameters:

cometContext -

MessagesBusCometHandler

protected MessagesBusCometHandler(CometContext cometContext,
                                  MessagesBus.CometType cometType)

Create a new CometHandler associated with CometContext, supported the MessagesBus#CometType.

Parameters:

cometContext -

Method Detail

attach

public void attach(HttpServletResponse response)

The HttpServletResponse used to push back data,

Specified by:

attach in interface CometHandler<HttpServletResponse>

Parameters:

response -

onEvent

public void onEvent(CometEvent event)
             throws IOException

Invoked when a CometContext.notify(com.sun.grizzly.comet.CometEvent, int, java.nio.channels.SelectionKey) is executing a push.

Specified by:

onEvent in interface CometHandler<HttpServletResponse>

Parameters:

event -

Throws:

IOException

onInitialize

public void onInitialize(CometEvent event)
                  throws IOException

Not used.

Specified by:

onInitialize in interface CometHandler<HttpServletResponse>

Parameters:

event -

Throws:

IOException

onInterrupt

public void onInterrupt(CometEvent event)
                 throws IOException

Invoked when MessagesBus.expirationDelay value expire. The connection will be automatically resumed.

Specified by:

onInterrupt in interface CometHandler<HttpServletResponse>

Parameters:

event -

Throws:

IOException

onTerminate

public void onTerminate(CometEvent event)
                 throws IOException

Never invoked as Grizly Comet CometContext API aren't exposed.

Specified by:

onTerminate in interface CometHandler<HttpServletResponse>

Throws:

IOException