|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--com.ibm.dse.base.DSEOperation | +--com.ibm.dse.base.DSEServerOperation | +--com.ibm.dse.appl.forwarding.server.ForwardingServerOperation
This server operation performs the retrieving of a store record forward the transaction message in the record to the host. It will update both the Store table and the Journal table based on the result it returned. This operation will be able to retrieve the Store service, the Journal service and also the Host service which implements CommonCommunicationsService interface.
Fields inherited from class com.ibm.dse.base.DSEOperation |
aOperationRepliedListener,
externalizer |
Constructor Summary | |
ForwardingServerOperation()
ForwardingServerOperation constructor |
|
ForwardingServerOperation(java.lang.String anOperationName)
ForwardingServerOperation constructor |
|
ForwardingServerOperation(java.lang.String anOperationName,
Context aParentContext)
Constructor passing an operation and a context. |
|
ForwardingServerOperation(java.lang.String anOperationName,
java.lang.String aParentContext)
Constructor passing an operation name and a string representation of the parent context. |
Method Summary | |
void |
execute()
Performs the operation. |
void |
forwardAllRecords()
Implementation for the interface ForwarderRetrieveInterface. |
void |
forwardRecordsWithCollection(java.util.Enumeration collection)
Implementation for the interface ForwarderRetrieveInterface. |
void |
forwardRecordsWithCriteria(java.lang.String whereClause)
Implementation for the interface ForwarderRetrieveInterface. |
void |
forwardRecordWithID(int identifier)
Implementation for the interface ForwarderRetrieveInterface. |
JournalService |
getJournalService()
Retrieves the Journal service from the context and opens the connection to the Journal table. |
Store |
getStoreService()
Retrives the Store service from context and open the connection to the Store table. |
void |
initializeForwarder()
Retrieves the forwarder class name from the externalized data elements file and tries to construct the class. |
void |
updateEJ(int value)
Update Journal value based on the forward result. |
Methods inherited from class com.ibm.dse.base.DSEServerOperation |
getCSReplyFormat,
getCSRequestFormat,
getOriginWorkstation,
runInSession,
setCSReplyFormat,
setCSRequestFormat,
setOriginWorkstation,
updateContext |
Methods inherited from class java.lang.Object |
clone,
equals,
finalize,
getClass,
hashCode,
notify,
notifyAll,
wait,
wait,
wait |
Constructor Detail |
public ForwardingServerOperation()
public ForwardingServerOperation(java.lang.String anOperationName) throws java.io.IOException
anOperationName
- java.lang.Stringpublic ForwardingServerOperation(java.lang.String anOperationName, Context aParentContext) throws java.io.IOException, DSEInvalidRequestException
anOperationName
- java.lang.StringaParentContext
- com.ibm.dse.base.Contextpublic ForwardingServerOperation(java.lang.String anOperationName, java.lang.String aParentContext) throws java.io.IOException, DSEObjectNotFoundException, DSEInvalidRequestException
anOperationName
- java.lang.StringaParentContext
- java.lang.StringMethod Detail |
public void execute() throws java.lang.Exception
public void forwardAllRecords() throws DSEException, java.io.IOException
public void forwardRecordsWithCollection(java.util.Enumeration collection) throws DSEException, java.io.IOException
collection
- java.util.Enumeration, a collection for store record idspublic void forwardRecordsWithCriteria(java.lang.String whereClause) throws DSEException, java.io.IOException
whereCluase
- java.lang.String representation of an SQL statementpublic void forwardRecordWithID(int identifier) throws DSEException, java.io.IOException
identifier
- int, the store record idpublic JournalService getJournalService() throws DSEException
public Store getStoreService() throws DSEException
public void initializeForwarder() throws DSEObjectNotFoundException, java.lang.ClassNotFoundException, java.lang.InstantiationException, java.lang.IllegalAccessException
public void updateEJ(int value) throws DSEException
value
- int, forward result
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |