Package org.yamcs.http.websocket

Class CommandQueueResource

java.lang.Object

org.yamcs.http.websocket.CommandQueueResource

All Implemented Interfaces:

CommandQueueListener, WebSocketResource

public class CommandQueueResource
extends Object
implements WebSocketResource, CommandQueueListener

Provides realtime command queue subscription via web.

Constructor Summary

Constructors

Constructor	Description
CommandQueueResource(ConnectedWebSocketClient client)

Method Summary

Modifier and Type	Method	Description
void	commandAdded(CommandQueue q, PreparedCommand pc)
void	commandRejected(CommandQueue q, PreparedCommand pc)
void	commandSent(CommandQueue q, PreparedCommand pc)
void	commandUpdated(CommandQueue q, PreparedCommand pc)
String	getName()
void	selectProcessor(Processor processor)
void	socketClosed()	Called when the web socket is closed
WebSocketReply	subscribe(WebSocketDecodeContext ctx, WebSocketDecoder decoder)
void	unselectProcessor()
WebSocketReply	unsubscribe(WebSocketDecodeContext ctx, WebSocketDecoder decoder)
void	updateQueue(CommandQueue q)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.yamcs.commanding.CommandQueueListener

commandQueueRegistered, commandQueueUnregistered, commandUnhandled

Methods inherited from interface org.yamcs.http.websocket.WebSocketResource

processRequest, subscribe, subscribeAll, unsubscribeAll

Constructor Detail

CommandQueueResource

public CommandQueueResource(ConnectedWebSocketClient client)

Method Detail

getName

public String getName()

Specified by:

getName in interface WebSocketResource

subscribe

public WebSocketReply subscribe(WebSocketDecodeContext ctx,
                                WebSocketDecoder decoder)
                         throws WebSocketException

Specified by:

subscribe in interface WebSocketResource

Throws:

WebSocketException

unsubscribe

public WebSocketReply unsubscribe(WebSocketDecodeContext ctx,
                                  WebSocketDecoder decoder)
                           throws WebSocketException

Specified by:

unsubscribe in interface WebSocketResource

Throws:

WebSocketException

unselectProcessor

public void unselectProcessor()

Specified by:

unselectProcessor in interface WebSocketResource

selectProcessor

public void selectProcessor(Processor processor)
                     throws ProcessorException

Specified by:

selectProcessor in interface WebSocketResource

Throws:

ProcessorException

updateQueue

public void updateQueue(CommandQueue q)

Specified by:

updateQueue in interface CommandQueueListener

commandAdded

public void commandAdded(CommandQueue q,
                         PreparedCommand pc)

Specified by:

commandAdded in interface CommandQueueListener

commandUpdated

public void commandUpdated(CommandQueue q,
                           PreparedCommand pc)

Specified by:

commandUpdated in interface CommandQueueListener

commandRejected

public void commandRejected(CommandQueue q,
                            PreparedCommand pc)

Specified by:

commandRejected in interface CommandQueueListener

commandSent

public void commandSent(CommandQueue q,
                        PreparedCommand pc)

Specified by:

commandSent in interface CommandQueueListener

socketClosed

public void socketClosed()

Description copied from interface: WebSocketResource

Called when the web socket is closed

Specified by:

socketClosed in interface WebSocketResource