java.lang.Object
com.tangosol.net.queue.WrapperNamedQueue<E>
com.oracle.coherence.grpc.proxy.common.concurrent.queue.NamedQueueProxy<E>
All Implemented Interfaces:
NamedCollection, NamedQueue<E>, Releasable, ObservableCollection<E>, AutoCloseable, Iterable<E>, Collection<E>, Queue<E>

public class NamedQueueProxy<E> extends com.tangosol.net.queue.WrapperNamedQueue<E>
  • Nested Class Summary

    Nested classes/interfaces inherited from interface com.tangosol.net.NamedCollection

    NamedCollection.Option
  • Constructor Summary

    Constructors
    Constructor
    Description
    NamedQueueProxy(NamedQueue<E> queue, boolean fCompatible)
    Create a NamedQueueProxy.
  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    Return true if this queue is serialization compatible.

    Methods inherited from class com.tangosol.net.queue.WrapperNamedQueue

    add, addAll, addListener, addListener, append, clear, contains, containsAll, destroy, element, equals, getDescription, getName, getQueue, getQueueNameHash, getQueueStatistics, getService, hashCode, isActive, isDestroyed, isEmpty, isReleased, iterator, offer, peek, poll, release, remove, remove, removeAll, removeListener, removeListener, retainAll, size, toArray, toArray, toString

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

    Methods inherited from interface java.util.Collection

    parallelStream, removeIf, spliterator, stream, toArray

    Methods inherited from interface java.lang.Iterable

    forEach

    Methods inherited from interface com.tangosol.net.NamedQueue

    isReady

    Methods inherited from interface com.tangosol.net.Releasable

    close
  • Constructor Details

    • NamedQueueProxy

      public NamedQueueProxy(NamedQueue<E> queue, boolean fCompatible)
      Create a NamedQueueProxy.
      Parameters:
      queue - the wrapped NamedQueue
      fCompatible - true if this queue is serialization compatible
  • Method Details

    • isCompatible

      public boolean isCompatible()
      Return true if this queue is serialization compatible.
      Returns:
      true if this queue is serialization compatible