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 and Description
AbstractQueueApi()

Method Summary

Modifier and Type	Method and Description
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)
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	listQueueEntries(T ctx, ListQueueEntriesRequest request, Observer<ListQueueEntriesResponse> observer) List command queue entries
abstract void	listQueues(T ctx, ListQueuesRequest request, Observer<ListQueuesResponse> observer) List command queues
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
 

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
 

listQueueEntries

public abstract void listQueueEntries(T ctx,
                                      ListQueueEntriesRequest request,
                                      Observer<ListQueueEntriesResponse> observer)

  List command queue entries
 

updateQueueEntry

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

  Update a command queue entry
 

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>