public class EntityCacheConnection
extends org.eclipse.persistence.internal.sessions.coordination.broadcast.BroadcastRemoteConnection
Modifier and Type | Class and Description |
---|---|
static class |
EntityCacheConnection.Message |
Modifier and Type | Field and Description |
---|---|
protected ClusterManagerAPI |
clusterManager |
protected Metadata |
metadata |
protected QueryCacheManager |
queryCacheManager |
Constructor and Description |
---|
EntityCacheConnection(org.eclipse.persistence.sessions.coordination.RemoteCommandManager rcm) |
EntityCacheConnection(org.eclipse.persistence.sessions.coordination.RemoteCommandManager rcm,
ClusterManagerAPI clusterManager) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
areAllResourcesFreedOnClose() |
protected void |
closeInternal() |
protected void |
createDisplayString() |
protected java.lang.Object |
executeCommandInternal(java.lang.Object command) |
protected void |
invalidateQueryCache(java.lang.Object command) |
boolean |
isLocal() |
void |
onMessage(EntityCacheConnection.Message message) |
protected boolean |
shouldCheckServiceId() |
close, executeCommand, executeCommand, failDeserializeMessage, getInfo, getInfoExt, getState, getTopicName, isActive, isClosed, isClosing, logDebugAfterPublish, logDebugBeforePublish, logDebugOnReceiveMessage, processReceivedObject, toString
protected Metadata metadata
protected QueryCacheManager queryCacheManager
protected ClusterManagerAPI clusterManager
public EntityCacheConnection(org.eclipse.persistence.sessions.coordination.RemoteCommandManager rcm, ClusterManagerAPI clusterManager)
public EntityCacheConnection(org.eclipse.persistence.sessions.coordination.RemoteCommandManager rcm)
public boolean isLocal()
protected java.lang.Object executeCommandInternal(java.lang.Object command)
executeCommandInternal
in class org.eclipse.persistence.internal.sessions.coordination.broadcast.BroadcastRemoteConnection
public void onMessage(EntityCacheConnection.Message message)
protected boolean areAllResourcesFreedOnClose()
areAllResourcesFreedOnClose
in class org.eclipse.persistence.internal.sessions.coordination.broadcast.BroadcastRemoteConnection
protected void closeInternal()
closeInternal
in class org.eclipse.persistence.internal.sessions.coordination.broadcast.BroadcastRemoteConnection
protected void createDisplayString()
createDisplayString
in class org.eclipse.persistence.internal.sessions.coordination.broadcast.BroadcastRemoteConnection
protected boolean shouldCheckServiceId()
shouldCheckServiceId
in class org.eclipse.persistence.internal.sessions.coordination.broadcast.BroadcastRemoteConnection
protected void invalidateQueryCache(java.lang.Object command)