Package org.cometd.websocket.server.common

Class AbstractWebSocketTransport.AbstractWebSocketScheduler

java.lang.Object

org.cometd.websocket.server.common.AbstractWebSocketTransport.AbstractWebSocketScheduler

All Implemented Interfaces:

AbstractServerTransport.Scheduler

Enclosing class:

AbstractWebSocketTransport<S>

protected abstract class AbstractWebSocketTransport.AbstractWebSocketScheduler
extends Object
implements AbstractServerTransport.Scheduler

Field Summary

Fields

Modifier and Type	Field	Description
protected org.slf4j.Logger	_logger

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractWebSocketScheduler(BayeuxContext context)

Method Summary

Modifier and Type	Method	Description
void	cancel()
protected boolean	cancelMetaConnectTask(ServerSessionImpl session)
protected abstract void	close(int code, String reason)
void	onClose(int code, String reason)
void	onError(Throwable failure)
void	onMessage(S wsSession, String data)
void	schedule()
protected abstract void	schedule(boolean timeout, ServerMessage.Mutable expiredConnectReply)
protected void	schedule(S wsSession, boolean timeout, ServerMessage.Mutable expiredConnectReply)
protected void	send(S wsSession, List<? extends ServerMessage> messages, int batchSize, org.eclipse.jetty.util.Callback callback)
protected void	send(S wsSession, ServerSessionImpl session, boolean sendQueue, boolean scheduleExpiration, List<ServerMessage.Mutable> replies)

Methods inherited from class java.lang.Object

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

Field Details

_logger

protected final org.slf4j.Logger _logger

Constructor Details

AbstractWebSocketScheduler

protected AbstractWebSocketScheduler(BayeuxContext context)

Method Details

send

protected void send(S wsSession, List<? extends ServerMessage> messages, int batchSize, org.eclipse.jetty.util.Callback callback)

onClose

public void onClose(int code, String reason)

onError

public void onError(Throwable failure)

cancelMetaConnectTask

protected boolean cancelMetaConnectTask(ServerSessionImpl session)

onMessage

public void onMessage(S wsSession, String data)

send

protected void send(S wsSession, ServerSessionImpl session, boolean sendQueue, boolean scheduleExpiration, List<ServerMessage.Mutable> replies)

close

protected abstract void close(int code, String reason)

cancel

public void cancel()

Specified by:

cancel in interface AbstractServerTransport.Scheduler

schedule

public void schedule()

Specified by:

schedule in interface AbstractServerTransport.Scheduler

schedule

protected abstract void schedule(boolean timeout, ServerMessage.Mutable expiredConnectReply)

schedule

protected void schedule(S wsSession, boolean timeout, ServerMessage.Mutable expiredConnectReply)