Package com.oracle.coherence.grpc.proxy.common.concurrent.queue

Class NamedQueueProxyProtocol

java.lang.Object
com.oracle.coherence.grpc.proxy.common.BaseProxyProtocol<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest,com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse>
com.oracle.coherence.grpc.proxy.common.concurrent.queue.NamedQueueProxyProtocol
All Implemented Interfaces:
GrpcServiceProtocol<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest,com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse>, NamedQueueProtocol<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest,com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse>
public class NamedQueueProxyProtocol extends BaseProxyProtocol<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest,com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> implements NamedQueueProtocol<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest,com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse>
The server size named queue protocol.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    protected class 
    NamedQueueProxyProtocol.QueueCacheListener
    A NamedCacheDeactivationListener to receive truncate and destroy events for the queue.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected final LongArray<NamedQueue<Binary>>
    m_aQueue
    An array of NamedQueue instances indexed by the queue identifier.
    protected final Map<String,Integer>
    m_mapQueue
    The map of queue names to queue identifiers.

    Fields inherited from class com.oracle.coherence.grpc.proxy.common.BaseProxyProtocol

    f_lock, m_ccf, m_connection, m_destroyedIds, m_eventObserver, m_proxy, m_serializer, m_service

    Fields inherited from interface com.oracle.coherence.grpc.GrpcServiceProtocol

    PRIORITY_NORMAL

    Fields inherited from interface com.oracle.coherence.grpc.NamedQueueProtocol

    PROTOCOL_NAME, SUPPORTED_VERSION, VERSION

  • Constructor Summary

    Constructors
    Constructor
    Description
    NamedQueueProxyProtocol()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected NamedDeque<Binary>
    assertDeque(int queueId)
     
    protected NamedQueue<Binary>
    assertQueue(int queueId)
     
    void
    close()
    Close this protocol.
    protected void
    completePeekOrPoll(Binary binResult, int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)
     
    protected com.google.protobuf.Any
    getMessage(com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest request)
     
    Class<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest>
    getRequestType()
    Return the type of the request messages.
    Class<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse>
    getResponseType()
    Return the type of the response messages.
    protected void
    initInternal(GrpcService service, com.oracle.coherence.grpc.messages.proxy.v1.InitRequest request, int nVersion, UUID clientUUID)
     
    protected void
    onClear(int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)
     
    protected void
    onDestroyQueue(int nId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)
     
    protected void
    onEnsureQueue(com.oracle.coherence.grpc.messages.concurrent.queue.v1.EnsureQueueRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)
     
    protected void
    onIsEmpty(int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)
     
    protected void
    onIsReady(int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)
     
    protected void
    onOfferHead(int queueId, com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)
     
    protected void
    onOfferTail(int queueId, com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)
     
    protected void
    onPeekHead(int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)
     
    protected void
    onPeekTail(int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)
     
    protected void
    onPollHead(int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)
     
    protected void
    onPollTail(int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)
     
    protected void
    onRequestInternal(com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)
     
    protected void
    onSize(int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)
     
    protected com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse.Builder
    response(int queueId)
    Create a NamedQueueResponse.Builder with the queue identifier set to the specified value.
    protected com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse
    response(int queueId, com.google.protobuf.Any any)
     
    protected Binary
    unpackBinary(com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest request)
    Return a BytesValue from a NamedQueueRequest converted to a Binary.

    Methods inherited from class com.oracle.coherence.grpc.proxy.common.BaseProxyProtocol

    complete, complete, complete, complete, complete, complete, completeKeyValue, completeMapStream, completeMapStream, completeSetStream, completeSetStream, fromBinary, fromByteString, fromByteString, getSerializer, init, onRequest, unpack

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface com.oracle.coherence.grpc.GrpcServiceProtocol

    getPriority, getSerializer, init, onError, onRequest

    Methods inherited from interface com.oracle.coherence.grpc.NamedQueueProtocol

    getProtocol, getSupportedVersion, getVersion

  • Field Details

  • Constructor Details

    • NamedQueueProxyProtocol

      public NamedQueueProxyProtocol()

  • Method Details

    • getRequestType

      public Class<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest> getRequestType()
      Description copied from interface: GrpcServiceProtocol
      Return the type of the request messages.
      Specified by:
      getRequestType in interface GrpcServiceProtocol<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest,com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse>
      Returns:
      the type of the request messages

    • getResponseType

      public Class<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> getResponseType()
      Description copied from interface: GrpcServiceProtocol
      Return the type of the response messages.
      Specified by:
      getResponseType in interface GrpcServiceProtocol<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest,com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse>
      Returns:
      the type of the response messages

    • initInternal

      protected void initInternal(GrpcService service, com.oracle.coherence.grpc.messages.proxy.v1.InitRequest request, int nVersion, UUID clientUUID)
      Specified by:
      initInternal in class BaseProxyProtocol<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest,com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse>

    • close

      public void close()
      Description copied from interface: GrpcServiceProtocol
      Close this protocol.
      Specified by:
      close in interface GrpcServiceProtocol<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest,com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse>
      Overrides:
      close in class BaseProxyProtocol<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest,com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse>

    • onRequestInternal

      protected void onRequestInternal(com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)
      Specified by:
      onRequestInternal in class BaseProxyProtocol<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest,com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse>

    • response

      protected com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse response(int queueId, com.google.protobuf.Any any)
      Specified by:
      response in class BaseProxyProtocol<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest,com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse>

    • getMessage

      protected com.google.protobuf.Any getMessage(com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest request)
      Specified by:
      getMessage in class BaseProxyProtocol<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest,com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse>

    • onEnsureQueue

      protected void onEnsureQueue(com.oracle.coherence.grpc.messages.concurrent.queue.v1.EnsureQueueRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)

    • onClear

      protected void onClear(int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)

    • onDestroyQueue

      protected void onDestroyQueue(int nId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)

    • onIsEmpty

      protected void onIsEmpty(int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)

    • onIsReady

      protected void onIsReady(int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)

    • onOfferTail

      protected void onOfferTail(int queueId, com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)

    • onOfferHead

      protected void onOfferHead(int queueId, com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest request, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)

    • onPollHead

      protected void onPollHead(int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)

    • onPeekHead

      protected void onPeekHead(int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)

    • onPollTail

      protected void onPollTail(int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)

    • onPeekTail

      protected void onPeekTail(int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)

    • onSize

      protected void onSize(int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)

    • completePeekOrPoll

      protected void completePeekOrPoll(Binary binResult, int queueId, io.grpc.stub.StreamObserver<com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse> observer)

    • assertQueue

      protected NamedQueue<Binary> assertQueue(int queueId)

    • assertDeque

      protected NamedDeque<Binary> assertDeque(int queueId)

    • response

      protected com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueResponse.Builder response(int queueId)
      Create a NamedQueueResponse.Builder with the queue identifier set to the specified value.
      Parameters:
      queueId - the queue identifier
      Returns:
      a NamedQueueResponse.Builder with the queue identifier set to the specified value

    • unpackBinary

      protected Binary unpackBinary(com.oracle.coherence.grpc.messages.concurrent.queue.v1.NamedQueueRequest request)
      Return a BytesValue from a NamedQueueRequest converted to a Binary.
      Parameters:
      request - the NamedQueueRequest to get the BytesValue from
      Returns:
      the BytesValue from a NamedQueueRequest converted to a Binary