Package io.jmix.eclipselink.impl.support

Class JmixEclipseLinkRemoteConnection

java.lang.Object

org.eclipse.persistence.internal.sessions.coordination.RemoteConnection

org.eclipse.persistence.internal.sessions.coordination.broadcast.BroadcastRemoteConnection

io.jmix.eclipselink.impl.support.JmixEclipseLinkRemoteConnection

All Implemented Interfaces:

Serializable

@Component("eclipselink_JmixEclipseLinkRemoteConnection")
@Scope("prototype")
public class JmixEclipseLinkRemoteConnection
extends org.eclipse.persistence.internal.sessions.coordination.broadcast.BroadcastRemoteConnection

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected EclipseLinkChannelSupplier	channelSupplier
protected ExtendedEntities	extendedEntities
protected Metadata	metadata
protected QueryCacheManager	queryCacheManager
protected StandardSerialization	serialization

Fields inherited from class org.eclipse.persistence.internal.sessions.coordination.broadcast.BroadcastRemoteConnection

displayString, info, infoExt, rcm, state, STATE_ACTIVE, STATE_CLOSED, STATE_CLOSING, topicName

Fields inherited from class org.eclipse.persistence.internal.sessions.coordination.RemoteConnection

serviceId

Constructor Summary

Constructors

Constructor	Description
JmixEclipseLinkRemoteConnection(org.eclipse.persistence.sessions.coordination.RemoteCommandManager rcm)

Method Summary

Modifier and Type	Method	Description
protected boolean	areAllResourcesFreedOnClose()
protected void	closeInternal()
protected void	createDisplayString()
protected Object	executeCommandInternal(Object command)
protected void	init()
protected void	invalidateQueryCache(Object command)
boolean	isLocal()
void	onMessage(org.springframework.messaging.Message<?> message)
protected boolean	shouldCheckServiceId()

Methods inherited from class org.eclipse.persistence.internal.sessions.coordination.broadcast.BroadcastRemoteConnection

close, executeCommand, executeCommand, failDeserializeMessage, getInfo, getInfoExt, getState, getTopicName, isActive, isClosed, isClosing, logDebugAfterPublish, logDebugBeforePublish, logDebugOnReceiveMessage, processReceivedObject, toString

Methods inherited from class org.eclipse.persistence.internal.sessions.coordination.RemoteConnection

getServiceId, setServiceId

Methods inherited from class java.lang.Object

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

Field Details

metadata

@Autowired
protected Metadata metadata

extendedEntities

@Autowired
protected ExtendedEntities extendedEntities

queryCacheManager

@Autowired
protected QueryCacheManager queryCacheManager

channelSupplier

@Autowired(required=false)
protected EclipseLinkChannelSupplier channelSupplier

serialization

@Autowired
protected StandardSerialization serialization

Constructor Details

JmixEclipseLinkRemoteConnection

public JmixEclipseLinkRemoteConnection(org.eclipse.persistence.sessions.coordination.RemoteCommandManager rcm)

Method Details

init

@PostConstruct
protected void init()

isLocal

public boolean isLocal()

executeCommandInternal

protected Object executeCommandInternal(Object command)

Specified by:

executeCommandInternal in class org.eclipse.persistence.internal.sessions.coordination.broadcast.BroadcastRemoteConnection

onMessage

public void onMessage(org.springframework.messaging.Message<?> message)

areAllResourcesFreedOnClose

protected boolean areAllResourcesFreedOnClose()

Overrides:

areAllResourcesFreedOnClose in class org.eclipse.persistence.internal.sessions.coordination.broadcast.BroadcastRemoteConnection

closeInternal

protected void closeInternal()

Specified by:

closeInternal in class org.eclipse.persistence.internal.sessions.coordination.broadcast.BroadcastRemoteConnection

createDisplayString

protected void createDisplayString()

Overrides:

createDisplayString in class org.eclipse.persistence.internal.sessions.coordination.broadcast.BroadcastRemoteConnection

shouldCheckServiceId

protected boolean shouldCheckServiceId()

Overrides:

shouldCheckServiceId in class org.eclipse.persistence.internal.sessions.coordination.broadcast.BroadcastRemoteConnection

invalidateQueryCache

protected void invalidateQueryCache(Object command)