Module org.yamcs.api

Package org.yamcs.protobuf

Class QueueApiClient

java.lang.Object

org.yamcs.protobuf.AbstractQueueApi<Void>

org.yamcs.protobuf.QueueApiClient

All Implemented Interfaces:

Api<Void>

public class QueueApiClient
extends AbstractQueueApi<Void>

Constructor Summary

Constructors

Constructor	Description
QueueApiClient(MethodHandler handler)

Method Summary

Modifier and Type	Method	Description
final void	acceptCommand(Void ctx, AcceptCommandRequest request, Observer<com.google.protobuf.Empty> observer)	Accept a queued command
final void	blockQueue(Void ctx, BlockQueueRequest request, Observer<Commanding.CommandQueueInfo> observer)	Block a command queue
final void	disableQueue(Void ctx, DisableQueueRequest request, Observer<Commanding.CommandQueueInfo> observer)	Disable a command queue
final void	enableQueue(Void ctx, EnableQueueRequest request, Observer<Commanding.CommandQueueInfo> observer)	Enable a command queue
final void	getQueue(Void ctx, GetQueueRequest request, Observer<Commanding.CommandQueueInfo> observer)	Get a command queue
final void	listQueuedCommands(Void ctx, ListQueuedCommandsRequest request, Observer<ListQueuedCommandsResponse> observer)	List queued commands
final void	listQueues(Void ctx, ListQueuesRequest request, Observer<ListQueuesResponse> observer)	List command queues
final void	rejectCommand(Void ctx, RejectCommandRequest request, Observer<com.google.protobuf.Empty> observer)	Reject a queued command
final void	subscribeQueueEvents(Void ctx, SubscribeQueueEventsRequest request, Observer<Commanding.CommandQueueEvent> observer)	Receive updates on queue events
final void	subscribeQueueStatistics(Void ctx, SubscribeQueueStatisticsRequest request, Observer<Commanding.CommandQueueInfo> observer)	Receive updates on queue stats
final void	updateQueue(Void ctx, EditQueueRequest request, Observer<Commanding.CommandQueueInfo> observer)	Update a command queue
final void	updateQueueEntry(Void ctx, EditQueueEntryRequest request, Observer<com.google.protobuf.Empty> observer)	Update a command queue entry

Methods inherited from class org.yamcs.protobuf.AbstractQueueApi

callMethod, callMethod, getDescriptorForType, getRequestPrototype, getResponsePrototype

Methods inherited from class java.lang.Object

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

Constructor Details

QueueApiClient

public QueueApiClient(MethodHandler handler)

Method Details

listQueues

public final void listQueues(Void ctx,
 ListQueuesRequest request,
 Observer<ListQueuesResponse> observer)

  List command queues
 

Specified by:

listQueues in class AbstractQueueApi<Void>

getQueue

public final void getQueue(Void ctx,
 GetQueueRequest request,
 Observer<Commanding.CommandQueueInfo> observer)

  Get a command queue
 

Specified by:

getQueue in class AbstractQueueApi<Void>

updateQueue

public final void updateQueue(Void ctx,
 EditQueueRequest request,
 Observer<Commanding.CommandQueueInfo> observer)

  Update a command queue
 

Specified by:

updateQueue in class AbstractQueueApi<Void>

enableQueue

public final void enableQueue(Void ctx,
 EnableQueueRequest request,
 Observer<Commanding.CommandQueueInfo> observer)

  Enable a command queue
 

Specified by:

enableQueue in class AbstractQueueApi<Void>

disableQueue

public final void disableQueue(Void ctx,
 DisableQueueRequest request,
 Observer<Commanding.CommandQueueInfo> observer)

  Disable a command queue
 

Specified by:

disableQueue in class AbstractQueueApi<Void>

blockQueue

public final void blockQueue(Void ctx,
 BlockQueueRequest request,
 Observer<Commanding.CommandQueueInfo> observer)

  Block a command queue
 

Specified by:

blockQueue in class AbstractQueueApi<Void>

subscribeQueueStatistics

public final void subscribeQueueStatistics(Void ctx,
 SubscribeQueueStatisticsRequest request,
 Observer<Commanding.CommandQueueInfo> observer)

  Receive updates on queue stats
 

Specified by:

subscribeQueueStatistics in class AbstractQueueApi<Void>

subscribeQueueEvents

public final void subscribeQueueEvents(Void ctx,
 SubscribeQueueEventsRequest request,
 Observer<Commanding.CommandQueueEvent> observer)

  Receive updates on queue events
 

Specified by:

subscribeQueueEvents in class AbstractQueueApi<Void>

listQueuedCommands

public final void listQueuedCommands(Void ctx,
 ListQueuedCommandsRequest request,
 Observer<ListQueuedCommandsResponse> observer)

  List queued commands
 

Specified by:

listQueuedCommands in class AbstractQueueApi<Void>

updateQueueEntry

public final void updateQueueEntry(Void ctx,
 EditQueueEntryRequest request,
 Observer<com.google.protobuf.Empty> observer)

  Update a command queue entry
 

Specified by:

updateQueueEntry in class AbstractQueueApi<Void>

acceptCommand

public final void acceptCommand(Void ctx,
 AcceptCommandRequest request,
 Observer<com.google.protobuf.Empty> observer)

  Accept a queued command
 

Specified by:

acceptCommand in class AbstractQueueApi<Void>

rejectCommand

public final void rejectCommand(Void ctx,
 RejectCommandRequest request,
 Observer<com.google.protobuf.Empty> observer)

  Reject a queued command
 

Specified by:

rejectCommand in class AbstractQueueApi<Void>