Module org.cometd.server

Package org.cometd.server.http

Class AbstractHttpScheduler

java.lang.Object

org.cometd.server.http.AbstractHttpScheduler

All Implemented Interfaces:

Runnable, AbstractServerTransport.Scheduler, AbstractHttpTransport.HttpScheduler

public abstract class AbstractHttpScheduler
extends Object
implements Runnable, AbstractHttpTransport.HttpScheduler

Nested Class Summary

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

AbstractServerTransport.Scheduler.None

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	cancel(Throwable cause)	Invoked when the transport wants to cancel with the given cause 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)
TransportContext	getContext()
ServerMessage.Mutable	getMessage()
long	getMetaConnectCycle()
Promise<Void>	getPromise()
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

Methods inherited from interface org.cometd.server.AbstractServerTransport.Scheduler

cancel

Constructor Details

AbstractHttpScheduler

protected AbstractHttpScheduler(AbstractHttpTransport transport,
 TransportContext context,
 Promise<Void> promise,
 ServerMessage.Mutable message,
 long timeout)

Method Details

getContext

public TransportContext getContext()

getPromise

public Promise<Void> getPromise()

getMessage

public ServerMessage.Mutable getMessage()

Specified by:

getMessage in interface AbstractServerTransport.Scheduler

Returns:

the message associated with this scheduler.

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(Throwable cause)

Description copied from interface: AbstractServerTransport.Scheduler

Invoked when the transport wants to cancel with the given cause 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

dispatch

protected abstract void dispatch(boolean timeout)

toString

public String toString()

Overrides:

toString in class Object