Module org.eclipse.persistence.extension

Package org.eclipse.persistence.internal.sessions.coordination.jgroups

Class JGroupsRemoteConnection

java.lang.Object

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

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

org.eclipse.persistence.internal.sessions.coordination.jgroups.JGroupsRemoteConnection

All Implemented Interfaces:

Serializable

public class JGroupsRemoteConnection
extends BroadcastRemoteConnection

Purpose: Define the implementation of the abstract RemoteConnection for JGroups.

Description: Executing commands implementation of RemoteConnection is done via JGroups JChannel.

Since:

EclipseLink 2.5

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected org.jgroups.JChannel	channel
protected boolean	isLocal

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
JGroupsRemoteConnection(RemoteCommandManager rcm)	Creates local connections.
JGroupsRemoteConnection(RemoteCommandManager rcm, org.jgroups.JChannel channel, boolean isLocalConnectionBeingCreated)	INTERNAL: Constructor creating either a local or external connection.

Method Summary

Modifier and Type	Method	Description
protected boolean	areAllResourcesFreedOnClose()	INTERNAL: Indicates whether all the resources used by connection are freed after close method returns.
protected void	closeInternal()	INTERNAL: This method is called by close method.
protected void	createDisplayString()	INTERNAL: Used for debug logging
protected Object	executeCommandInternal(Object command)	INTERNAL: Execute the remote command.
boolean	isLocal()	INTERNAL: Indicates whether connection is local (subscriber) or external (publisher).
protected String	logDebugMessage(org.jgroups.Message message)	INTERNAL:
void	onMessage(org.jgroups.Message message)	INTERNAL: Process received JGroups message.
protected boolean	shouldCheckServiceId()	INTERNAL: Return whether a BroadcastConnection should check a ServiceId against its own ServiceId to avoid the processing of Commands with the same ServiceId.

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

channel

protected transient org.jgroups.JChannel channel

isLocal

protected boolean isLocal

Constructor Details

JGroupsRemoteConnection

public JGroupsRemoteConnection(RemoteCommandManager rcm,
 org.jgroups.JChannel channel,
 boolean isLocalConnectionBeingCreated)

INTERNAL: Constructor creating either a local or external connection.

JGroupsRemoteConnection

public JGroupsRemoteConnection(RemoteCommandManager rcm)

Creates local connections.

Method Details

isLocal

public boolean isLocal()

INTERNAL: Indicates whether connection is local (subscriber) or external (publisher).

executeCommandInternal

protected Object executeCommandInternal(Object command)
                                 throws Exception

INTERNAL: Execute the remote command. The result of execution is returned. This method is used only by external (publishing) connection.

Specified by:

executeCommandInternal in class BroadcastRemoteConnection

Throws:

Exception

onMessage

public void onMessage(org.jgroups.Message message)

INTERNAL: Process received JGroups message. This method is used only by local (listening) connection.

areAllResourcesFreedOnClose

protected boolean areAllResourcesFreedOnClose()

INTERNAL: Indicates whether all the resources used by connection are freed after close method returns.

Overrides:

areAllResourcesFreedOnClose in class BroadcastRemoteConnection

closeInternal

protected void closeInternal()

INTERNAL: This method is called by close method.

Specified by:

closeInternal in class BroadcastRemoteConnection

logDebugMessage

protected String logDebugMessage(org.jgroups.Message message)

INTERNAL:

createDisplayString

protected void createDisplayString()

INTERNAL: Used for debug logging

Overrides:

createDisplayString in class BroadcastRemoteConnection

shouldCheckServiceId

protected boolean shouldCheckServiceId()

INTERNAL: Return whether a BroadcastConnection should check a ServiceId against its own ServiceId to avoid the processing of Commands with the same ServiceId. Not required for JGroups.

Overrides:

shouldCheckServiceId in class BroadcastRemoteConnection

Returns:

boolean