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
ConstructorsModifierConstructorDescriptionprotected
LongPollScheduler
(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout) -
Method Summary
Modifier and TypeMethodDescriptionvoid
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) long
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.toString()
-
Constructor Details
-
LongPollScheduler
protected LongPollScheduler(AbstractHttpTransport.Context context, Promise<Void> promise, ServerMessage.Mutable message, long timeout)
-
-
Method Details
-
getContext
-
getPromise
-
getMessage
- Specified by:
getMessage
in interfaceAbstractHttpTransport.HttpScheduler
-
getMetaConnectCycle
public long getMetaConnectCycle()- Specified by:
getMetaConnectCycle
in interfaceAbstractServerTransport.Scheduler
- Returns:
- the cycle number for suspended
/meta/connect
s.
-
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 interfaceAbstractServerTransport.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 interfaceAbstractServerTransport.Scheduler
-
destroy
public void destroy()Description copied from interface:AbstractServerTransport.Scheduler
Invoked when the transport wants to abort communication.- Specified by:
destroy
in interfaceAbstractServerTransport.Scheduler
-
run
public void run() -
onStartAsync
public void onStartAsync(javax.servlet.AsyncEvent event) - Specified by:
onStartAsync
in interfacejavax.servlet.AsyncListener
-
onTimeout
public void onTimeout(javax.servlet.AsyncEvent event) - Specified by:
onTimeout
in interfacejavax.servlet.AsyncListener
-
onComplete
- Specified by:
onComplete
in interfacejavax.servlet.AsyncListener
- Throws:
IOException
-
onError
public void onError(javax.servlet.AsyncEvent event) - Specified by:
onError
in interfacejavax.servlet.AsyncListener
-
dispatch
protected abstract void dispatch(boolean timeout) -
toString
-