Package org.cometd.server.http

Class AbstractHttpTransport.LongPollScheduler

java.lang.Object

org.cometd.server.http.AbstractHttpTransport.LongPollScheduler

All Implemented Interfaces:

Runnable, EventListener, javax.servlet.AsyncListener, AbstractServerTransport.Scheduler, AbstractHttpTransport.HttpScheduler

Direct Known Subclasses:

AbstractStreamHttpTransport.DispatchingLongPollScheduler

Enclosing class:

AbstractHttpTransport

protected abstract class AbstractHttpTransport.LongPollScheduler
extends Object
implements Runnable, AbstractHttpTransport.HttpScheduler, javax.servlet.AsyncListener

Nested Class Summary

Nested classes/interfaces inherited from interface org.cometd.server.AbstractServerTransport.Scheduler

AbstractServerTransport.Scheduler.None

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	LongPollScheduler(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout)

Method Summary

Modifier and Type	Method	Description
void	cancel()	Invoked when the transport wants to cancel scheduled operations that will trigger when the /meta/connect timeout fires.
void	destroy()	Invoked when the transport wants to abort communication.
protected abstract void	dispatch(boolean timeout)
AbstractHttpTransport.Context	getContext()
ServerMessage.Mutable	getMessage()
long	getMetaConnectCycle()
Promise<Void>	getPromise()
void	onComplete(javax.servlet.AsyncEvent asyncEvent)
void	onError(javax.servlet.AsyncEvent event)
void	onStartAsync(javax.servlet.AsyncEvent event)
void	onTimeout(javax.servlet.AsyncEvent event)
void	run()
void	schedule()	Invoked when the transport wants to send queued messages, and possibly a /meta/connect reply.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

LongPollScheduler

protected LongPollScheduler(AbstractHttpTransport.Context context,
 Promise<Void> promise,
 ServerMessage.Mutable message,
 long timeout)

Method Details

getContext

public AbstractHttpTransport.Context getContext()

getPromise

public Promise<Void> getPromise()

getMessage

public ServerMessage.Mutable getMessage()

Specified by:

getMessage in interface AbstractHttpTransport.HttpScheduler

getMetaConnectCycle

public long getMetaConnectCycle()

Specified by:

getMetaConnectCycle in interface AbstractServerTransport.Scheduler

Returns:

the cycle number for suspended /meta/connects.

schedule

public void schedule()

Description copied from interface: AbstractServerTransport.Scheduler

Invoked when the transport wants to send queued messages, and possibly a /meta/connect reply.

Specified by:

schedule in interface AbstractServerTransport.Scheduler

cancel

public void cancel()

Description copied from interface: AbstractServerTransport.Scheduler

Invoked when the transport wants to cancel scheduled operations that will trigger when the /meta/connect timeout fires.

Specified by:

cancel in interface AbstractServerTransport.Scheduler

destroy

public void destroy()

Description copied from interface: AbstractServerTransport.Scheduler

Invoked when the transport wants to abort communication.

Specified by:

destroy in interface AbstractServerTransport.Scheduler

run

public void run()

Specified by:

run in interface Runnable

onStartAsync

public void onStartAsync(javax.servlet.AsyncEvent event)

Specified by:

onStartAsync in interface javax.servlet.AsyncListener

onTimeout

public void onTimeout(javax.servlet.AsyncEvent event)

Specified by:

onTimeout in interface javax.servlet.AsyncListener

onComplete

public void onComplete(javax.servlet.AsyncEvent asyncEvent)
                throws IOException

Specified by:

onComplete in interface javax.servlet.AsyncListener

Throws:

IOException

onError

public void onError(javax.servlet.AsyncEvent event)

Specified by:

onError in interface javax.servlet.AsyncListener

dispatch

protected abstract void dispatch(boolean timeout)

toString

public String toString()

Overrides:

toString in class Object