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
All Methods Instance Methods Concrete Methods 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 closedWebSocketReply
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 interfaceWebSocketResource
-
subscribe
public WebSocketReply subscribe(WebSocketDecodeContext ctx, WebSocketDecoder decoder) throws WebSocketException
- Specified by:
subscribe
in interfaceWebSocketResource
- Throws:
WebSocketException
-
unsubscribe
public WebSocketReply unsubscribe(WebSocketDecodeContext ctx, WebSocketDecoder decoder) throws WebSocketException
- Specified by:
unsubscribe
in interfaceWebSocketResource
- Throws:
WebSocketException
-
unselectProcessor
public void unselectProcessor()
- Specified by:
unselectProcessor
in interfaceWebSocketResource
-
selectProcessor
public void selectProcessor(Processor processor) throws ProcessorException
- Specified by:
selectProcessor
in interfaceWebSocketResource
- Throws:
ProcessorException
-
updateQueue
public void updateQueue(CommandQueue q)
- Specified by:
updateQueue
in interfaceCommandQueueListener
-
commandAdded
public void commandAdded(CommandQueue q, PreparedCommand pc)
- Specified by:
commandAdded
in interfaceCommandQueueListener
-
commandUpdated
public void commandUpdated(CommandQueue q, PreparedCommand pc)
- Specified by:
commandUpdated
in interfaceCommandQueueListener
-
commandRejected
public void commandRejected(CommandQueue q, PreparedCommand pc)
- Specified by:
commandRejected
in interfaceCommandQueueListener
-
commandSent
public void commandSent(CommandQueue q, PreparedCommand pc)
- Specified by:
commandSent
in interfaceCommandQueueListener
-
socketClosed
public void socketClosed()
Description copied from interface:WebSocketResource
Called when the web socket is closed- Specified by:
socketClosed
in interfaceWebSocketResource
-
-