Package org.yamcs.protobuf

Class AbstractQueueApi<T>

java.lang.Object

org.yamcs.protobuf.AbstractQueueApi<T>

All Implemented Interfaces:

Api<T>

Direct Known Subclasses:

QueueApiClient

public abstract class AbstractQueueApi<T>
extends Object
implements Api<T>

Constructor Summary

Constructors

Constructor	Description
AbstractQueueApi()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractQueueApi

public AbstractQueueApi()

Method Detail

listQueues

public abstract void listQueues(T ctx,
                                ListQueuesRequest request,
                                Observer<ListQueuesResponse> observer)

  List command queues
 

getQueue

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

  Get a command queue
 

updateQueue

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

  Update a command queue
 

enableQueue

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

  Enable a command queue
 

disableQueue

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

  Disable a command queue
 

blockQueue

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

  Block a command queue
 

subscribeQueueStatistics

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

  Receive updates on queue stats
 

subscribeQueueEvents

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

  Receive updates on queue events
 

listQueuedCommands

public abstract void listQueuedCommands(T ctx,
                                        ListQueuedCommandsRequest request,
                                        Observer<ListQueuedCommandsResponse> observer)

  List queued commands
 

updateQueueEntry

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

  Update a command queue entry
 

acceptCommand

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

  Accept a queued command
 

rejectCommand

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

  Reject a queued command
 

getDescriptorForType

public final com.google.protobuf.Descriptors.ServiceDescriptor getDescriptorForType()

Specified by:

getDescriptorForType in interface Api<T>

getRequestPrototype

public final com.google.protobuf.Message getRequestPrototype(com.google.protobuf.Descriptors.MethodDescriptor method)

Specified by:

getRequestPrototype in interface Api<T>

getResponsePrototype

public final com.google.protobuf.Message getResponsePrototype(com.google.protobuf.Descriptors.MethodDescriptor method)

Specified by:

getResponsePrototype in interface Api<T>

callMethod

public final void callMethod(com.google.protobuf.Descriptors.MethodDescriptor method,
                             T ctx,
                             com.google.protobuf.Message request,
                             Observer<com.google.protobuf.Message> future)

Specified by:

callMethod in interface Api<T>

callMethod

public final Observer<com.google.protobuf.Message> callMethod(com.google.protobuf.Descriptors.MethodDescriptor method,
                                                              T ctx,
                                                              Observer<com.google.protobuf.Message> future)

Specified by:

callMethod in interface Api<T>