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 boolean
add(Object paramObject)
boolean
addAll(Collection paramCollection)
void
clear()
Object
clone()
void
closeBroker()
Close the broker that is used to service this proxy.boolean
contains(Object object)
boolean
containsAll(Collection c)
Object
copy(Object paramObject)
Return an unproxied copy of the given instance.Object
element()
boolean
equals(Object paramObject)
Broker
getBroker()
Get the broker that is used to service this proxy.BrokerFactory
getBrokerFactory()
ChangeTracker
getChangeTracker()
Return the change tracker for this proxy, or null if none.int
getDelayedField()
Returns the expected field index even if this collection was detached.OpenJPAStateManager
getDelayedOwner()
Returns a state manager that can service this proxy even if the collection was detached.Class
getElementType()
The collection element type.OpenJPAStateManager
getOwner()
Return the owning object.int
getOwnerField()
Return the owning field index.OpenJPAStateManager
getOwnerStateManager()
Returns the state manager of the owning instance.int
hashCode()
boolean
isDelayLoad()
boolean
isDetached()
Returns whether the proxy is detached.boolean
isDirectAccess()
Returns whether the caller has direct-call access to the proxied object.boolean
isEmpty()
Iterator
iterator()
void
load()
Load the proxy if it was delay-loaded.ProxyCollection
newInstance(Class paramClass, Comparator paramComparator, boolean paramBoolean1, boolean paramBoolean2)
Create a new instance of this proxy type.boolean
offer(Object paramObject)
Object
peek()
Object
poll()
Object
remove()
boolean
remove(Object paramObject)
boolean
removeAll(Collection paramCollection)
boolean
retainAll(Collection paramCollection)
protected void
setChangeTracker(CollectionChangeTracker ct)
void
setDirectAccess(boolean direct)
Sets whether the caller has direct-call access to the proxied object.protected void
setElementType(Class<?> elemType)
void
setOwner(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.int
size()
Object[]
toArray()
Object[]
toArray(Object[] array)
Object[]
toArray(IntFunction generator)
protected Object
writeReplace()
-
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:Proxy
Reset 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:Proxy
Return the owning object.
-
getOwnerField
public int getOwnerField()
Description copied from interface:Proxy
Return the owning field index.- Specified by:
getOwnerField
in interfaceProxy
-
clone
public Object clone() throws CloneNotSupportedException
- Overrides:
clone
in classObject
- Throws:
CloneNotSupportedException
-
getChangeTracker
public ChangeTracker getChangeTracker()
Description copied from interface:Proxy
Return the change tracker for this proxy, or null if none.- Specified by:
getChangeTracker
in interfaceProxy
-
setChangeTracker
protected void setChangeTracker(CollectionChangeTracker ct)
-
copy
public Object copy(Object paramObject)
Description copied from interface:Proxy
Return 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:ProxyCollection
The collection element type.- Specified by:
getElementType
in interfaceProxyCollection
-
setElementType
protected void setElementType(Class<?> elemType)
-
newInstance
public ProxyCollection newInstance(Class paramClass, Comparator paramComparator, boolean paramBoolean1, boolean paramBoolean2)
Description copied from interface:ProxyCollection
Create a new instance of this proxy type.- Specified by:
newInstance
in interfaceProxyCollection
-
add
public boolean add(Object paramObject)
- Specified by:
add
in interfaceCollection
- Specified by:
add
in interfaceQueue
- Overrides:
add
in classPriorityQueue
-
clear
public void clear()
- Specified by:
clear
in interfaceCollection
- Overrides:
clear
in classPriorityQueue
-
iterator
public Iterator iterator()
- Specified by:
iterator
in interfaceCollection
- Specified by:
iterator
in interfaceIterable
- Overrides:
iterator
in classPriorityQueue
-
remove
public boolean remove(Object paramObject)
- Specified by:
remove
in interfaceCollection
- Overrides:
remove
in classPriorityQueue
-
poll
public Object poll()
- Specified by:
poll
in interfaceQueue
- Overrides:
poll
in classPriorityQueue
-
offer
public boolean offer(Object paramObject)
- Specified by:
offer
in interfaceQueue
- Overrides:
offer
in classPriorityQueue
-
addAll
public boolean addAll(Collection paramCollection)
- Specified by:
addAll
in interfaceCollection
- Overrides:
addAll
in classAbstractQueue
-
remove
public Object remove()
- Specified by:
remove
in interfaceQueue
- Overrides:
remove
in classAbstractQueue
-
removeAll
public boolean removeAll(Collection paramCollection)
- Specified by:
removeAll
in interfaceCollection
- Overrides:
removeAll
in classPriorityQueue
-
retainAll
public boolean retainAll(Collection paramCollection)
- Specified by:
retainAll
in interfaceCollection
- Overrides:
retainAll
in classPriorityQueue
-
writeReplace
protected Object writeReplace() throws ObjectStreamException
- Throws:
ObjectStreamException
-
size
public int size()
- Specified by:
size
in interfaceCollection
- Overrides:
size
in classPriorityQueue
-
isEmpty
public boolean isEmpty()
- Specified by:
isEmpty
in interfaceCollection
- Overrides:
isEmpty
in classAbstractCollection
-
contains
public boolean contains(Object object)
- Specified by:
contains
in interfaceCollection
- Overrides:
contains
in classPriorityQueue
-
toArray
public Object[] toArray()
- Specified by:
toArray
in interfaceCollection
- Overrides:
toArray
in classPriorityQueue
-
toArray
public Object[] toArray(Object[] array)
- Specified by:
toArray
in interfaceCollection
- Overrides:
toArray
in classPriorityQueue
-
toArray
public Object[] toArray(IntFunction generator)
- Specified by:
toArray
in interfaceCollection
-
containsAll
public boolean containsAll(Collection c)
- Specified by:
containsAll
in interfaceCollection
- Overrides:
containsAll
in classAbstractCollection
-
element
public Object element()
- Specified by:
element
in interfaceQueue
- Overrides:
element
in classAbstractQueue
-
peek
public Object peek()
- Specified by:
peek
in interfaceQueue
- Overrides:
peek
in classPriorityQueue
-
equals
public boolean equals(Object paramObject)
- Specified by:
equals
in interfaceCollection
- Overrides:
equals
in classObject
-
hashCode
public int hashCode()
- Specified by:
hashCode
in interfaceCollection
- Overrides:
hashCode
in classObject
-
getDelayedField
public int getDelayedField()
Description copied from interface:DelayedProxy
Returns the expected field index even if this collection was detached.- Specified by:
getDelayedField
in interfaceDelayedProxy
-
getDelayedOwner
public OpenJPAStateManager getDelayedOwner()
Description copied from interface:DelayedProxy
Returns a state manager that can service this proxy even if the collection was detached.- Specified by:
getDelayedOwner
in interfaceDelayedProxy
-
isDirectAccess
public boolean isDirectAccess()
Description copied from interface:DelayedProxy
Returns 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:
isDirectAccess
in interfaceDelayedProxy
-
setDirectAccess
public void setDirectAccess(boolean direct)
Description copied from interface:DelayedProxy
Sets 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:
setDirectAccess
in interfaceDelayedProxy
-
getBrokerFactory
public BrokerFactory getBrokerFactory()
-
load
public void load()
Description copied from interface:DelayedProxy
Load the proxy if it was delay-loaded.- Specified by:
load
in interfaceDelayedProxy
-
getBroker
public Broker getBroker()
Description copied from interface:DelayedProxy
Get the broker that is used to service this proxy.- Specified by:
getBroker
in interfaceDelayedProxy
-
closeBroker
public void closeBroker()
Description copied from interface:DelayedProxy
Close the broker that is used to service this proxy.- Specified by:
closeBroker
in interfaceDelayedProxy
-
getOwnerStateManager
public OpenJPAStateManager getOwnerStateManager()
Description copied from interface:DelayedProxy
Returns the state manager of the owning instance.- Specified by:
getOwnerStateManager
in interfaceDelayedProxy
-
isDetached
public boolean isDetached()
Description copied from interface:DelayedProxy
Returns whether the proxy is detached.- Specified by:
isDetached
in interfaceDelayedProxy
-
isDelayLoad
public boolean isDelayLoad()
-
-