Package org.yamcs.protobuf

Class AbstractQueueApi<T>

java.lang.Object

org.yamcs.protobuf.AbstractQueueApi<T>

All Implemented Interfaces:

Api<T>

Direct Known Subclasses:

QueueApi, 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
final void	callMethod(com.google.protobuf.Descriptors.MethodDescriptor method, T ctx, com.google.protobuf.Message request, Observer<com.google.protobuf.Message> future)
final 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
final com.google.protobuf.Descriptors.ServiceDescriptor	getDescriptorForType()
abstract void	getQueue(T ctx, GetQueueRequest request, Observer<Commanding.CommandQueueInfo> observer)	Get a command queue
final com.google.protobuf.Message	getRequestPrototype(com.google.protobuf.Descriptors.MethodDescriptor method)
final 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

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractQueueApi

public AbstractQueueApi()

Method Details

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
 

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
 

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>