EclipseLink 1.0_1.0M2 API Reference - Incubation

org.eclipse.persistence.sessions.remote.corba.sun
Class CORBARemoteSessionControllerDispatcher

java.lang.Object
  extended by org.omg.CORBA.portable.ObjectImpl
      extended by org.eclipse.persistence.sessions.remote.corba.sun._CORBARemoteSessionControllerImplBase
          extended by org.eclipse.persistence.sessions.remote.corba.sun.CORBARemoteSessionControllerDispatcher
All Implemented Interfaces:
java.io.Serializable, CORBARemoteSessionController, CORBARemoteSessionControllerOperations, org.omg.CORBA.Object, org.omg.CORBA.portable.IDLEntity, org.omg.CORBA.portable.InvokeHandler

public class CORBARemoteSessionControllerDispatcher
extends _CORBARemoteSessionControllerImplBase

RemoteSessionController sits between the remote session and the session. Any interaction between these two classes takes place through this object. As the object extends unicast remote object it listens to only single remote session during runtime.

See Also:
Serialized Form

Field Summary
protected  RemoteSessionController controller
          Store the real controller.
 
Constructor Summary
CORBARemoteSessionControllerDispatcher(AbstractSession session)
           
 
Method Summary
 Transporter beginTransaction()
          Begin a transaction on the database.
 Transporter commitRootUnitOfWork(Transporter remoteUnitOfWork)
          Remote unit of work after serialization is commited locally.
 Transporter commitTransaction()
          Commit a transaction on the database.
 Transporter cursoredStreamClose(Transporter remoteCursoredStreamID)
          Used for closing cursored streams across RMI.
 Transporter cursoredStreamNextPage(Transporter remoteCursoredStream, int pageSize)
          Retrieve next page size of objects from the remote cursored stream
 Transporter cursoredStreamSize(Transporter remoteCursoredStreamOid)
          Return the cursored stream size
 Transporter cursorSelectObjects(Transporter remoteTransporter)
          Returns a remote cursor stub in a transporter
 Transporter executeNamedQuery(Transporter nameTransporter, Transporter classTransporter, Transporter argumentsTransporter)
          A remote query after serialization is executed locally.
 Transporter executeQuery(Transporter query)
          A remote query after serialization is executed locally.
protected  RemoteSessionController getController()
          Return the controller.
 Transporter getDefaultReadOnlyClasses()
          Get the default read-only classes
 Transporter getDescriptor(Transporter theClass)
          Extract descriptor from the session
 Transporter getLogin()
          Get the associated session login.
 Transporter getSequenceNumberNamed(Transporter remoteFunctionCall)
          INTERNAL: Get the value returned by remote function call
 Transporter initializeIdentityMapsOnServerSession()
           
 Transporter instantiateRemoteValueHolderOnServer(Transporter remoteValueHolder)
          The corresponding original value holder is instantiated.
 Transporter processCommand(Transporter remoteTransporter)
          INTERNAL: This method is intended to be used by by sessions that wish to execute a command on a remote session
 Transporter rollbackTransaction()
          Rollback a transaction on the database.
 Transporter scrollableCursorAbsolute(Transporter remoteScrollableCursorOid, int rows)
          Moves the cursor to the given row number in the result set
 Transporter scrollableCursorAfterLast(Transporter remoteScrollableCursorOid)
          Moves the cursor to the end of the result set, just after the last row.
 Transporter scrollableCursorBeforeFirst(Transporter remoteScrollableCursor)
          Moves the cursor to the front of the result set, just before the first row
 Transporter scrollableCursorClose(Transporter remoteScrollableCursorOid)
          Used for closing scrollable cursor across RMI.
 Transporter scrollableCursorCurrentIndex(Transporter remoteScrollableCursor)
          Retrieves the current row index number
 Transporter scrollableCursorFirst(Transporter remoteScrollableCursor)
          Moves the cursor to the first row in the result set
 Transporter scrollableCursorIsAfterLast(Transporter remoteScrollableCursor)
          Indicates whether the cursor is after the last row in the result set.
 Transporter scrollableCursorIsBeforeFirst(Transporter remoteScrollableCursor)
          Indicates whether the cursor is before the first row in the result set.
 Transporter scrollableCursorIsFirst(Transporter remoteScrollableCursor)
          Indicates whether the cursor is on the first row of the result set.
 Transporter scrollableCursorIsLast(Transporter remoteScrollableCursor)
          Indicates whether the cursor is on the last row of the result set.
 Transporter scrollableCursorLast(Transporter remoteScrollableCursor)
          Moves the cursor to the last row in the result set
 Transporter scrollableCursorNextObject(Transporter scrollableCursorOid)
          Retrieve next object from the scrollable cursor
 Transporter scrollableCursorPreviousObject(Transporter scrollableCursorOid)
          Retrieve previous object from the scrollable cursor
 Transporter scrollableCursorRelative(Transporter remoteScrollableCursor, int rows)
          Moves the cursor to the given row number in the result set
 Transporter scrollableCursorSize(Transporter remoteCursorOid)
          Return the cursor size
protected  void setController(RemoteSessionController controller)
          Set the controller.
 
Methods inherited from class org.eclipse.persistence.sessions.remote.corba.sun._CORBARemoteSessionControllerImplBase
_ids, _invoke
 
Methods inherited from class org.omg.CORBA.portable.ObjectImpl
_create_request, _create_request, _duplicate, _get_delegate, _get_domain_managers, _get_interface_def, _get_policy, _hash, _invoke, _is_a, _is_equivalent, _is_local, _non_existent, _orb, _release, _releaseReply, _request, _request, _servant_postinvoke, _servant_preinvoke, _set_delegate, _set_policy_override, equals, hashCode, toString
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.omg.CORBA.Object
_create_request, _create_request, _duplicate, _get_domain_managers, _get_interface_def, _get_policy, _hash, _is_a, _is_equivalent, _non_existent, _release, _request, _set_policy_override
 

Field Detail

controller

protected RemoteSessionController controller
Store the real controller.

Constructor Detail

CORBARemoteSessionControllerDispatcher

public CORBARemoteSessionControllerDispatcher(AbstractSession session)
Method Detail

processCommand

public Transporter processCommand(Transporter remoteTransporter)
INTERNAL: This method is intended to be used by by sessions that wish to execute a command on a remote session

Parameters:
remoteCommand - RemoteCommand The command to be executed on the remote session

beginTransaction

public Transporter beginTransaction()
Begin a transaction on the database.


commitRootUnitOfWork

public Transporter commitRootUnitOfWork(Transporter remoteUnitOfWork)
Remote unit of work after serialization is commited locally.


commitTransaction

public Transporter commitTransaction()
Commit a transaction on the database.


cursoredStreamClose

public Transporter cursoredStreamClose(Transporter remoteCursoredStreamID)
Used for closing cursored streams across RMI.


cursoredStreamNextPage

public Transporter cursoredStreamNextPage(Transporter remoteCursoredStream,
                                          int pageSize)
Retrieve next page size of objects from the remote cursored stream


cursoredStreamSize

public Transporter cursoredStreamSize(Transporter remoteCursoredStreamOid)
Return the cursored stream size


cursorSelectObjects

public Transporter cursorSelectObjects(Transporter remoteTransporter)
Returns a remote cursor stub in a transporter


executeNamedQuery

public Transporter executeNamedQuery(Transporter nameTransporter,
                                     Transporter classTransporter,
                                     Transporter argumentsTransporter)
A remote query after serialization is executed locally.


executeQuery

public Transporter executeQuery(Transporter query)
A remote query after serialization is executed locally.


getController

protected RemoteSessionController getController()
Return the controller. All work is dispatched to the controller. This is required to be protocol independent.


getDescriptor

public Transporter getDescriptor(Transporter theClass)
Extract descriptor from the session


getDefaultReadOnlyClasses

public Transporter getDefaultReadOnlyClasses()
Get the default read-only classes


getLogin

public Transporter getLogin()
Get the associated session login.


getSequenceNumberNamed

public Transporter getSequenceNumberNamed(Transporter remoteFunctionCall)
INTERNAL: Get the value returned by remote function call


initializeIdentityMapsOnServerSession

public Transporter initializeIdentityMapsOnServerSession()

instantiateRemoteValueHolderOnServer

public Transporter instantiateRemoteValueHolderOnServer(Transporter remoteValueHolder)
The corresponding original value holder is instantiated.


rollbackTransaction

public Transporter rollbackTransaction()
Rollback a transaction on the database.


scrollableCursorAbsolute

public Transporter scrollableCursorAbsolute(Transporter remoteScrollableCursorOid,
                                            int rows)
Moves the cursor to the given row number in the result set


scrollableCursorAfterLast

public Transporter scrollableCursorAfterLast(Transporter remoteScrollableCursorOid)
Moves the cursor to the end of the result set, just after the last row.


scrollableCursorBeforeFirst

public Transporter scrollableCursorBeforeFirst(Transporter remoteScrollableCursor)
Moves the cursor to the front of the result set, just before the first row


scrollableCursorClose

public Transporter scrollableCursorClose(Transporter remoteScrollableCursorOid)
Used for closing scrollable cursor across RMI.


scrollableCursorCurrentIndex

public Transporter scrollableCursorCurrentIndex(Transporter remoteScrollableCursor)
Retrieves the current row index number


scrollableCursorFirst

public Transporter scrollableCursorFirst(Transporter remoteScrollableCursor)
Moves the cursor to the first row in the result set


scrollableCursorIsAfterLast

public Transporter scrollableCursorIsAfterLast(Transporter remoteScrollableCursor)
Indicates whether the cursor is after the last row in the result set.


scrollableCursorIsBeforeFirst

public Transporter scrollableCursorIsBeforeFirst(Transporter remoteScrollableCursor)
Indicates whether the cursor is before the first row in the result set.


scrollableCursorIsFirst

public Transporter scrollableCursorIsFirst(Transporter remoteScrollableCursor)
Indicates whether the cursor is on the first row of the result set.


scrollableCursorIsLast

public Transporter scrollableCursorIsLast(Transporter remoteScrollableCursor)
Indicates whether the cursor is on the last row of the result set.


scrollableCursorLast

public Transporter scrollableCursorLast(Transporter remoteScrollableCursor)
Moves the cursor to the last row in the result set


scrollableCursorNextObject

public Transporter scrollableCursorNextObject(Transporter scrollableCursorOid)
Retrieve next object from the scrollable cursor


scrollableCursorPreviousObject

public Transporter scrollableCursorPreviousObject(Transporter scrollableCursorOid)
Retrieve previous object from the scrollable cursor


scrollableCursorRelative

public Transporter scrollableCursorRelative(Transporter remoteScrollableCursor,
                                            int rows)
Moves the cursor to the given row number in the result set


scrollableCursorSize

public Transporter scrollableCursorSize(Transporter remoteCursorOid)
Return the cursor size


setController

protected void setController(RemoteSessionController controller)
Set the controller. All work is dispatched to the controller. This is required to be protocol independent.


EclipseLink 1.0_1.0M2 API Reference - Incubation