Package org.apache.openjpa.util.proxy
Class DelayedPriorityQueueProxy
- java.lang.Object
-
- java.util.AbstractCollection<E>
-
- java.util.AbstractQueue<E>
-
- java.util.PriorityQueue
-
- org.apache.openjpa.util.proxy.DelayedPriorityQueueProxy
-
- All Implemented Interfaces:
Serializable,Iterable,Collection,Queue,Proxy,DelayedProxy,ProxyCollection
public class DelayedPriorityQueueProxy extends PriorityQueue implements ProxyCollection, DelayedProxy
PriorityQueue proxy with delay loading capability. Allows non-indexed add and remove operations to occur on an unloaded collection. Operations that require a load will trigger a load.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description DelayedPriorityQueueProxy()DelayedPriorityQueueProxy(int paramInt)DelayedPriorityQueueProxy(int paramInt, Comparator paramComparator)DelayedPriorityQueueProxy(Collection paramCollection)DelayedPriorityQueueProxy(PriorityQueue paramPriorityQueue)DelayedPriorityQueueProxy(SortedSet paramSortedSet)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanadd(Object paramObject)booleanaddAll(Collection paramCollection)voidclear()Objectclone()voidcloseBroker()Close the broker that is used to service this proxy.booleancontains(Object object)booleancontainsAll(Collection c)Objectcopy(Object paramObject)Return an unproxied copy of the given instance.Objectelement()booleanequals(Object paramObject)BrokergetBroker()Get the broker that is used to service this proxy.BrokerFactorygetBrokerFactory()ChangeTrackergetChangeTracker()Return the change tracker for this proxy, or null if none.intgetDelayedField()Returns the expected field index even if this collection was detached.OpenJPAStateManagergetDelayedOwner()Returns a state manager that can service this proxy even if the collection was detached.ClassgetElementType()The collection element type.OpenJPAStateManagergetOwner()Return the owning object.intgetOwnerField()Return the owning field index.OpenJPAStateManagergetOwnerStateManager()Returns the state manager of the owning instance.inthashCode()booleanisDelayLoad()booleanisDetached()Returns whether the proxy is detached.booleanisDirectAccess()Returns whether the caller has direct-call access to the proxied object.booleanisEmpty()Iteratoriterator()voidload()Load the proxy if it was delay-loaded.ProxyCollectionnewInstance(Class paramClass, Comparator paramComparator, boolean paramBoolean1, boolean paramBoolean2)Create a new instance of this proxy type.booleanoffer(Object paramObject)Objectpeek()Objectpoll()Objectremove()booleanremove(Object paramObject)booleanremoveAll(Collection paramCollection)booleanretainAll(Collection paramCollection)protected voidsetChangeTracker(CollectionChangeTracker ct)voidsetDirectAccess(boolean direct)Sets whether the caller has direct-call access to the proxied object.protected voidsetElementType(Class<?> elemType)voidsetOwner(OpenJPAStateManager paramOpenJPAStateManager, int paramInt)Reset the state of the proxy, and set the owning instance of the proxy and the name of the field it is assigned to.intsize()Object[]toArray()Object[]toArray(Object[] array)Object[]toArray(IntFunction generator)protected ObjectwriteReplace()-
Methods inherited from class java.util.PriorityQueue
comparator, forEach, removeIf, spliterator
-
Methods inherited from class java.util.AbstractCollection
toString
-
Methods inherited from class java.lang.Object
finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface java.util.Collection
parallelStream, removeIf, spliterator, stream
-
-
-
-
Constructor Detail
-
DelayedPriorityQueueProxy
public DelayedPriorityQueueProxy(int paramInt)
-
DelayedPriorityQueueProxy
public DelayedPriorityQueueProxy(int paramInt, Comparator paramComparator)
-
DelayedPriorityQueueProxy
public DelayedPriorityQueueProxy(Collection paramCollection)
-
DelayedPriorityQueueProxy
public DelayedPriorityQueueProxy(PriorityQueue paramPriorityQueue)
-
DelayedPriorityQueueProxy
public DelayedPriorityQueueProxy(SortedSet paramSortedSet)
-
DelayedPriorityQueueProxy
public DelayedPriorityQueueProxy()
-
-
Method Detail
-
setOwner
public void setOwner(OpenJPAStateManager paramOpenJPAStateManager, int paramInt)
Description copied from interface:ProxyReset the state of the proxy, and set the owning instance of the proxy and the name of the field it is assigned to. Set to null to indicate that the proxy is no longer managed.
-
getOwner
public OpenJPAStateManager getOwner()
Description copied from interface:ProxyReturn the owning object.
-
getOwnerField
public int getOwnerField()
Description copied from interface:ProxyReturn the owning field index.- Specified by:
getOwnerFieldin interfaceProxy
-
clone
public Object clone() throws CloneNotSupportedException
- Overrides:
clonein classObject- Throws:
CloneNotSupportedException
-
getChangeTracker
public ChangeTracker getChangeTracker()
Description copied from interface:ProxyReturn the change tracker for this proxy, or null if none.- Specified by:
getChangeTrackerin interfaceProxy
-
setChangeTracker
protected void setChangeTracker(CollectionChangeTracker ct)
-
copy
public Object copy(Object paramObject)
Description copied from interface:ProxyReturn an unproxied copy of the given instance. This method is used by proxy managers to create backup values for use in rollback.
-
getElementType
public Class getElementType()
Description copied from interface:ProxyCollectionThe collection element type.- Specified by:
getElementTypein interfaceProxyCollection
-
setElementType
protected void setElementType(Class<?> elemType)
-
newInstance
public ProxyCollection newInstance(Class paramClass, Comparator paramComparator, boolean paramBoolean1, boolean paramBoolean2)
Description copied from interface:ProxyCollectionCreate a new instance of this proxy type.- Specified by:
newInstancein interfaceProxyCollection
-
add
public boolean add(Object paramObject)
- Specified by:
addin interfaceCollection- Specified by:
addin interfaceQueue- Overrides:
addin classPriorityQueue
-
clear
public void clear()
- Specified by:
clearin interfaceCollection- Overrides:
clearin classPriorityQueue
-
iterator
public Iterator iterator()
- Specified by:
iteratorin interfaceCollection- Specified by:
iteratorin interfaceIterable- Overrides:
iteratorin classPriorityQueue
-
remove
public boolean remove(Object paramObject)
- Specified by:
removein interfaceCollection- Overrides:
removein classPriorityQueue
-
poll
public Object poll()
- Specified by:
pollin interfaceQueue- Overrides:
pollin classPriorityQueue
-
offer
public boolean offer(Object paramObject)
- Specified by:
offerin interfaceQueue- Overrides:
offerin classPriorityQueue
-
addAll
public boolean addAll(Collection paramCollection)
- Specified by:
addAllin interfaceCollection- Overrides:
addAllin classAbstractQueue
-
remove
public Object remove()
- Specified by:
removein interfaceQueue- Overrides:
removein classAbstractQueue
-
removeAll
public boolean removeAll(Collection paramCollection)
- Specified by:
removeAllin interfaceCollection- Overrides:
removeAllin classPriorityQueue
-
retainAll
public boolean retainAll(Collection paramCollection)
- Specified by:
retainAllin interfaceCollection- Overrides:
retainAllin classPriorityQueue
-
writeReplace
protected Object writeReplace() throws ObjectStreamException
- Throws:
ObjectStreamException
-
size
public int size()
- Specified by:
sizein interfaceCollection- Overrides:
sizein classPriorityQueue
-
isEmpty
public boolean isEmpty()
- Specified by:
isEmptyin interfaceCollection- Overrides:
isEmptyin classAbstractCollection
-
contains
public boolean contains(Object object)
- Specified by:
containsin interfaceCollection- Overrides:
containsin classPriorityQueue
-
toArray
public Object[] toArray()
- Specified by:
toArrayin interfaceCollection- Overrides:
toArrayin classPriorityQueue
-
toArray
public Object[] toArray(Object[] array)
- Specified by:
toArrayin interfaceCollection- Overrides:
toArrayin classPriorityQueue
-
toArray
public Object[] toArray(IntFunction generator)
- Specified by:
toArrayin interfaceCollection
-
containsAll
public boolean containsAll(Collection c)
- Specified by:
containsAllin interfaceCollection- Overrides:
containsAllin classAbstractCollection
-
element
public Object element()
- Specified by:
elementin interfaceQueue- Overrides:
elementin classAbstractQueue
-
peek
public Object peek()
- Specified by:
peekin interfaceQueue- Overrides:
peekin classPriorityQueue
-
equals
public boolean equals(Object paramObject)
- Specified by:
equalsin interfaceCollection- Overrides:
equalsin classObject
-
hashCode
public int hashCode()
- Specified by:
hashCodein interfaceCollection- Overrides:
hashCodein classObject
-
getDelayedField
public int getDelayedField()
Description copied from interface:DelayedProxyReturns the expected field index even if this collection was detached.- Specified by:
getDelayedFieldin interfaceDelayedProxy
-
getDelayedOwner
public OpenJPAStateManager getDelayedOwner()
Description copied from interface:DelayedProxyReturns a state manager that can service this proxy even if the collection was detached.- Specified by:
getDelayedOwnerin interfaceDelayedProxy
-
isDirectAccess
public boolean isDirectAccess()
Description copied from interface:DelayedProxyReturns whether the caller has direct-call access to the proxied object. Direct access allows calls to be made on the object without triggering a load or proxy state tracking callbacks.- Specified by:
isDirectAccessin interfaceDelayedProxy
-
setDirectAccess
public void setDirectAccess(boolean direct)
Description copied from interface:DelayedProxySets whether the caller has direct-call access to the proxied object. Direct access allows calls to be made on the object without triggering a load or proxy state tracking callbacks.- Specified by:
setDirectAccessin interfaceDelayedProxy
-
getBrokerFactory
public BrokerFactory getBrokerFactory()
-
load
public void load()
Description copied from interface:DelayedProxyLoad the proxy if it was delay-loaded.- Specified by:
loadin interfaceDelayedProxy
-
getBroker
public Broker getBroker()
Description copied from interface:DelayedProxyGet the broker that is used to service this proxy.- Specified by:
getBrokerin interfaceDelayedProxy
-
closeBroker
public void closeBroker()
Description copied from interface:DelayedProxyClose the broker that is used to service this proxy.- Specified by:
closeBrokerin interfaceDelayedProxy
-
getOwnerStateManager
public OpenJPAStateManager getOwnerStateManager()
Description copied from interface:DelayedProxyReturns the state manager of the owning instance.- Specified by:
getOwnerStateManagerin interfaceDelayedProxy
-
isDetached
public boolean isDetached()
Description copied from interface:DelayedProxyReturns whether the proxy is detached.- Specified by:
isDetachedin interfaceDelayedProxy
-
isDelayLoad
public boolean isDelayLoad()
-
-