org.eclipse.persistence.sessions.coordination

Interface CommandProcessor

All Known Implementing Classes:

org.eclipse.persistence.internal.sessions.AbstractSession, ClientSession, org.eclipse.persistence.internal.sessions.DatabaseSessionImpl, DistributedSession, RemoteSession, ServerSession, SessionBroker

public interface CommandProcessor

Purpose: Defines a pluggable interface for EclipseLink sessions and EclipseLink applications to be able to be on the receiving end of EclipseLink command objects.

Description: This interface represents the entity that both initiates (on the sending end) and processes (on the receiving end) remote commands. The implementation classes of this interface should be set on the CommandManager so that it can be invoked to process command messages as they get received from other remote command managers in the TopLink cluster. When the implementing class wants to send a remote command to other CommandProcessors then it invokes the CommandManager to do so. When running this remote command service in a EclipseLink application then the the Session class should be used as the implementation class for this interface. When running in a non-TopLink application then the application should provide the implementation class.

See Also:

Command, CommandManager

Author:

Steven Vo

Since:

OracleAS TopLink 10g (9.0.4)

Field Summary

Fields

Modifier and Type	Field and Description
static int	LOG_DEBUG
static int	LOG_ERROR
static int	LOG_INFO
static int	LOG_WARNING

Method Summary

Modifier and Type	Method and Description
void	endOperationProfile(java.lang.String operationName) Profile the operation.
CommandManager	getCommandManager() PUBLIC: Return the CommandManager that will invoke this CommandProcessor to process a command, and can be used to send remote commands out to other CommandProcessors in the cluster.
java.lang.Object	handleException(java.lang.RuntimeException exception) PUBLIC: Allow the implementation class to handle an exception thrown in in the remote command service.
void	incrementProfile(java.lang.String counter) Log the profile event.
void	logMessage(int logLevel, java.lang.String message) PUBLIC: Log a message to the application log output stream.
void	processCommand(java.lang.Object command) PUBLIC: Invoked by the CommandManager after it has received a Command object and has converted it to the application command format.
void	setCommandManager(CommandManager commandManager) PUBLIC: Set the CommandManager that will invoke this CommandProcessor to process a command, and can be used to send remote commands out to other CommandProcessors in the cluster.
boolean	shouldLogMessages(int logLevel) PUBLIC: Determine whether messages at the specified log level should be logged.
void	startOperationProfile(java.lang.String operationName) Profile the operation.
void	updateProfile(java.lang.String info, java.lang.Object value) Log the profile event.

Field Detail

LOG_DEBUG

static final int LOG_DEBUG

See Also:

Constant Field Values

LOG_INFO

static final int LOG_INFO

See Also:

Constant Field Values

LOG_WARNING

static final int LOG_WARNING

See Also:

Constant Field Values

LOG_ERROR

static final int LOG_ERROR

See Also:

Constant Field Values

Method Detail

processCommand

void processCommand(java.lang.Object command)

PUBLIC: Invoked by the CommandManager after it has received a Command object and has converted it to the application command format.

Parameters:

command - Application formatted command to be processed

getCommandManager

CommandManager getCommandManager()

PUBLIC: Return the CommandManager that will invoke this CommandProcessor to process a command, and can be used to send remote commands out to other CommandProcessors in the cluster.

Returns:

The remote command manager responsible for this CommandProcessor

setCommandManager

void setCommandManager(CommandManager commandManager)

PUBLIC: Set the CommandManager that will invoke this CommandProcessor to process a command, and can be used to send remote commands out to other CommandProcessors in the cluster.

Parameters:

commandManager - The remote command manager responsible for this CommandProcessor

shouldLogMessages

boolean shouldLogMessages(int logLevel)

PUBLIC: Determine whether messages at the specified log level should be logged. This will be invoked by the CommandManager as a short-circuiting mechanism to calling logMessage().

Parameters:

logLevel - A log constant that is one of LOG_ERROR, LOG_WARNING, LOG_INFO, LOG_DEBUG

Returns:

True if a message at the specified level should be logged and false if it should not

logMessage

void logMessage(int logLevel,
                java.lang.String message)

PUBLIC: Log a message to the application log output stream. If the specified log level is lower than the level configured in the CommandProcessor then the message should not be logged. The implementation class must map its logging system to the four supported levels: Error, Warning, Info and Debug.

Parameters:

logLevel - A log constant that is one of LOG_ERROR, LOG_WARNING, LOG_INFO, LOG_DEBUG

message - The message String that is to be logged

incrementProfile

void incrementProfile(java.lang.String counter)

Log the profile event.

updateProfile

void updateProfile(java.lang.String info,
                   java.lang.Object value)

Log the profile event.

startOperationProfile

void startOperationProfile(java.lang.String operationName)

Profile the operation.

endOperationProfile

void endOperationProfile(java.lang.String operationName)

Profile the operation.

handleException

java.lang.Object handleException(java.lang.RuntimeException exception)

PUBLIC: Allow the implementation class to handle an exception thrown in in the remote command service. The implementation may choose to simply rethrow the exception if it does not want to handle it. NOTE: Handlers that simply ignore exceptions may cause unexpected behavior that can be detrimental to the application and difficult to debug.

Parameters:

exception - The exception being thrown

Returns:

An object that is not currently used