Package com.oracle.coherence.grpc.proxy.common.cache

Class NamedCacheProxyProtocol.ChannelStub

java.lang.Object
com.tangosol.coherence.Component
com.tangosol.coherence.component.Net
com.tangosol.coherence.component.net.Extend
com.tangosol.coherence.component.net.extend.Channel
com.oracle.coherence.grpc.proxy.common.cache.NamedCacheProxyProtocol.ChannelStub
All Implemented Interfaces:
PofContext, PofSerializer, Serializer, com.tangosol.net.messaging.Channel, ObjectInputValidation, Serializable, Comparable
Enclosing class:
NamedCacheProxyProtocol
protected class NamedCacheProxyProtocol.ChannelStub extends com.tangosol.coherence.component.net.extend.Channel
A stub of an Extend Channel used to handle event messages.
See Also:

  • Nested Class Summary

    Nested classes/interfaces inherited from class com.tangosol.coherence.component.net.extend.Channel

    com.tangosol.coherence.component.net.extend.Channel.MessageAction

    Nested classes/interfaces inherited from interface com.tangosol.net.messaging.Channel

    com.tangosol.net.messaging.Channel.Receiver

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected final int
    m_cacheId
    The cache identifier.
    protected final boolean
    m_fCompatible
    true if the client's serializer is compatible with the underlying cache service serializer.

  • Constructor Summary

    Constructors
    Constructor
    Description
    ChannelStub(int cacheId, boolean fCompatible)
    Create the NamedCacheProxyProtocol.ChannelStub.

  • Method Summary

    Modifier and Type
    Method
    Description
    com.tangosol.net.messaging.Connection
    getConnection()
    Return the Connection that created this Channel.
    com.tangosol.coherence.component.util.daemon.queueProcessor.service.Peer
    getConnectionManager()
     
    boolean
    isSerializerCompatible()
    Return true if the client's serializer is compatible with the underlying cache service serializer.
    void
    send(com.tangosol.net.messaging.Message message)
    Asynchronously send a Message to the peer endpoint through this Channel over the underlying Connection.

    Methods inherited from class com.tangosol.coherence.component.net.extend.Channel

    __init, __initPrivate, assertOpen, calculateRequestTimeout, close, close, closeInternal, createMessage, deserialize, deserialize, execute, gateClose, gateEnter, gateExit, gateOpen, generateRequestId, get_ChildClasses, get_CLASS, get_Instance, getAccessAdapter, getAttribute, getAttributeMap, getAttributes, getClass, getClassName, getCloseThrowable, getDescription, getEmptySubject, getId, getMessageFactory, getPofSerializer, getReceiver, getRequest, getRequestArray, getSerializer, getSubject, getThreadGate, getUserTypeIdentifier, getUserTypeIdentifier, getUserTypeIdentifier, isActiveThread, isCloseNotify, isCloseOnExit, isLegacyPromotion, isOpen, isSecureContext, isUserType, isUserType, isUserType, onInit, onRequestCompleted, open, openInternal, post, receive, registerRequest, removeAttribute, request, request, send, serialize, serialize, setAccessAdapter, setAttribute, setAttributeMap, setCloseNotify, setCloseOnExit, setCloseThrowable, setConnection, setEmptySubject, setId, setLegacyPromotion, setMessageFactory, setOpen, setReceiver, setRequestArray, setSecureContext, setSerializer, setSubject, setThreadGate, unregisterRequest

    Methods inherited from class com.tangosol.coherence.component.net.Extend

    ensureRuntimeException, ensureRuntimeException, toString

    Methods inherited from class com.tangosol.coherence.Component

    _addChild, _assert, _assert, _assertFailed, _beep, _enumChildNames, _enumChildren, _enumChildrenInOrder, _findAncestor, _findChild, _findChild, _findChildClass, _findFeed, _findName, _findNextPosition, _findPreviousPosition, _imports, _init, _isAncestorOf, _isTraceEnabled, _linkChild, _makeApplication, _makeRemoteInstance, _makeRemoteObject, _newChild, _newInstance, _positionOf, _removeAllChildren, _removeChild, _trace, _trace, _trace, _trace, _unlinkChild, applyConfig, compareTo, get_DefaultRemoteName, get_Feed, get_Name, get_Order, get_Parent, get_Position, get_Reference, get_RemoteContext, get_RemoteName, get_RemoteObject, get_Sink, get_StackTrace, get_StateAux, getStackTrace, is_Constructed, is_Deserialized, onAdd, onRemove, saveConfig, set_Constructed, set_Feed, set_Order, set_Reference, set_Sink, set_StateAux, validateObject

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface com.tangosol.io.pof.PofContext

    isPreferJavaTime

    Methods inherited from interface com.tangosol.io.Serializer

    deserialize, getName

  • Field Details

    • m_cacheId

      protected final int m_cacheId
      The cache identifier.

    • m_fCompatible

      protected final boolean m_fCompatible
      true if the client's serializer is compatible with the underlying cache service serializer.

  • Constructor Details

    • ChannelStub

      public ChannelStub(int cacheId, boolean fCompatible)
      Create the NamedCacheProxyProtocol.ChannelStub.
      Parameters:
      cacheId - the cache identifier
      fCompatible - true if the client's serializer is compatible with the underlying cache service serializer

  • Method Details

    • send

      public void send(com.tangosol.net.messaging.Message message)
      Description copied from interface: com.tangosol.net.messaging.Channel
      Asynchronously send a Message to the peer endpoint through this Channel over the underlying Connection.
      Specified by:
      send in interface com.tangosol.net.messaging.Channel
      Overrides:
      send in class com.tangosol.coherence.component.net.extend.Channel
      Parameters:
      message - the Message to send

    • getConnection

      public com.tangosol.net.messaging.Connection getConnection()
      Description copied from interface: com.tangosol.net.messaging.Channel
      Return the Connection that created this Channel.
      Specified by:
      getConnection in interface com.tangosol.net.messaging.Channel
      Overrides:
      getConnection in class com.tangosol.coherence.component.net.extend.Channel
      Returns:
      the Connection that created this Channel

    • getConnectionManager

      public com.tangosol.coherence.component.util.daemon.queueProcessor.service.Peer getConnectionManager()
      Overrides:
      getConnectionManager in class com.tangosol.coherence.component.net.extend.Channel

    • isSerializerCompatible

      public boolean isSerializerCompatible()
      Return true if the client's serializer is compatible with the underlying cache service serializer.
      Returns:
      true if the client's serializer is compatible with the underlying cache service serializer