org.yamcs.web.websocket

Class WebSocketProcessorClient

java.lang.Object

org.yamcs.web.websocket.WebSocketProcessorClient

All Implemented Interfaces:

ManagementListener, ProcessorClient

public class WebSocketProcessorClient
extends Object
implements ProcessorClient, ManagementListener

Runs on the server side and oversees the life cycle of a client web socket connection to a Processor. Combines multiple types of subscriptions to keep them bundled as one client session.

Constructor Summary

Constructors

Constructor and Description
WebSocketProcessorClient(String yamcsInstance, WebSocketFrameHandler wsHandler, String applicationName, AuthenticationToken authToken)

Method Summary

Modifier and Type	Method and Description
String	getApplicationName()
AuthenticationToken	getAuthToken()
int	getClientId()
Processor	getProcessor()
String	getUsername()
WebSocketFrameHandler	getWebSocketFrameHandler()
void	instanceStateChanged(YamcsServerInstance ysi) Called when an instance state changes - for example when it is stopped/started
void	processorQuit() called when the processor is closing down
void	quit() Called when the socket is closed.
void	registerResource(String route, AbstractWebSocketResource resource)
void	switchProcessor(Processor newProcessor) change the connection to another processor

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.yamcs.management.ManagementListener

clientInfoChanged, clientInfoChanged, clientRegistered, clientUnregistered, processorAdded, processorClosed, processorStateChanged, serviceRegistered, serviceUnregistered, statisticsUpdated

Constructor Detail

WebSocketProcessorClient

public WebSocketProcessorClient(String yamcsInstance,
                                WebSocketFrameHandler wsHandler,
                                String applicationName,
                                AuthenticationToken authToken)

Method Detail

switchProcessor

public void switchProcessor(Processor newProcessor)
                     throws ProcessorException

Description copied from interface: ProcessorClient

change the connection to another processor

Specified by:

switchProcessor in interface ProcessorClient

Parameters:

newProcessor - - processor

Throws:

ProcessorException

getProcessor

public Processor getProcessor()

Specified by:

getProcessor in interface ProcessorClient

Returns:

the current processor the client is connected to

registerResource

public void registerResource(String route,
                             AbstractWebSocketResource resource)

getClientId

public int getClientId()

getAuthToken

public AuthenticationToken getAuthToken()

getWebSocketFrameHandler

public WebSocketFrameHandler getWebSocketFrameHandler()

processorQuit

public void processorQuit()

Description copied from interface: ProcessorClient

called when the processor is closing down

Specified by:

processorQuit in interface ProcessorClient

getUsername

public String getUsername()

Specified by:

getUsername in interface ProcessorClient

getApplicationName

public String getApplicationName()

Specified by:

getApplicationName in interface ProcessorClient

quit

public void quit()

Called when the socket is closed.

instanceStateChanged

public void instanceStateChanged(YamcsServerInstance ysi)

Description copied from interface: ManagementListener

Called when an instance state changes - for example when it is stopped/started

Specified by:

instanceStateChanged in interface ManagementListener