org.yamcs.web.websocket

Class AbstractWebSocketResource

java.lang.Object

org.yamcs.web.websocket.AbstractWebSocketResource

Direct Known Subclasses:

AlarmResource, CommandHistoryResource, CommandQueueResource, EventResource, LinkResource, ManagementResource, PacketResource, ParameterResource, ProcessorResource, StreamResource, TimeResource

public abstract class AbstractWebSocketResource
extends Object

A resource bundles a set of logically related operations. Instances of this class are created for every client session separately.

Field Summary

Fields

Modifier and Type	Field and Description
protected WebSocketProcessorClient	client
protected Processor	processor
protected WebSocketFrameHandler	wsHandler

Constructor Summary

Constructors

Constructor and Description
AbstractWebSocketResource(WebSocketProcessorClient client)

Method Summary

Modifier and Type	Method and Description
io.netty.channel.Channel	getChannel()
abstract WebSocketReply	processRequest(WebSocketDecodeContext ctx, WebSocketDecoder decoder) Process a request and return a reply.
abstract void	quit() Called when the web socket is closed
void	switchProcessor(Processor oldProcessor, Processor newProcessor)
protected void	verifyAuthorization(int requestId, SystemPrivilege systemPrivilege)

Methods inherited from class java.lang.Object

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

Field Detail

processor

protected Processor processor

client

protected WebSocketProcessorClient client

wsHandler

protected WebSocketFrameHandler wsHandler

Constructor Detail

AbstractWebSocketResource

public AbstractWebSocketResource(WebSocketProcessorClient client)

Method Detail

processRequest

public abstract WebSocketReply processRequest(WebSocketDecodeContext ctx,
                                              WebSocketDecoder decoder)
                                       throws WebSocketException

Process a request and return a reply. The reply can be null if the implementor of the resource takes care itself of sending the reply - this has been added because the parameterClient wants to send some date data immediately after reply

Throws:

WebSocketException

quit

public abstract void quit()

Called when the web socket is closed

switchProcessor

public void switchProcessor(Processor oldProcessor,
                            Processor newProcessor)
                     throws ProcessorException

Throws:

ProcessorException

getChannel

public io.netty.channel.Channel getChannel()

verifyAuthorization

protected void verifyAuthorization(int requestId,
                                   SystemPrivilege systemPrivilege)
                            throws WebSocketException

Throws:

WebSocketException