com.ibm.able.conversation
Class AblePlatformConversationAgent
java.lang.Object
|
+--com.ibm.able.AbleObject
|
+--com.ibm.able.AbleDefaultAgent
|
+--com.ibm.able.AbleRemoteDefaultAgent
|
+--com.ibm.able.platform.AblePlatformDefaultAgent
|
+--com.ibm.able.conversation.AblePlatformConversationAgent
- All Implemented Interfaces:
- AbleAgent, AbleBean, AbleBeanContainer, AbleBeanRemoteContainer, AbleDataBufferManager, AbleEventListener, AbleEventListenerManager, AbleEventListenerRemoteManager, AbleEventQueueManager, AbleEventQueueProcessor, AbleEventQueueRemoteManager, AblePlatformAgent, AblePropertyChangeManager, AbleRemoteAgent, AbleRemoteBean, AbleRemoteEventListener, AbleSerializable, AbleUserDefinedFunctionManager, AbleUserDefinedFunctionRemoteManager, java.util.EventListener, javax.agent.service.transport.MessageListener, java.beans.PropertyChangeListener, java.rmi.Remote, java.io.Serializable
- public class AblePlatformConversationAgent
- extends AblePlatformDefaultAgent
The AblePlatformConversationAgent class represents an agent that supports conversations
atop the Java Agent Services (JAS) platform.
NEW VERSION -- UNFINISHED
- See Also:
- Serialized Form
Fields inherited from class com.ibm.able.platform.AblePlatformDefaultAgent |
agentLastUpdate, agentMovable, agentStatus, agentSummary, agentToAutoRegister, agentToBindToRmi, agentType, agentVendor, agentVersion, myAgentInboxes, myJasAbleLocator, myJasAgentAttributes, myJasAgentDescription, myJasAgentDirectoryService, myJasAgentName, myJasAgentNamingService, myJasDefaultLocator, myJasMessageTransportService, myJasServiceRoot, myJasTransportSystem, myJasVerifiableDirectoryService, myJasVerifiableNamingService, myKeyPair, myPrincipal, myReceiveMessageMethod, myRequestKey, mySecSppt, myTrustLevel, myVerifiableAgentName |
Fields inherited from class com.ibm.able.AbleObject |
changed, chgSupport, comment, dataFlowEnabled, destBufferConnections, eventQueue, fileName, inputBuffer, listeners, logger, name, outputBuffer, parent, propertyConnectionMgr, sourceBufferConnections, state, stateChgSupport, trace |
Method Summary |
protected ConversationMetaData |
createMetaData()
Creates and returns a ConversationMetaData object compatible with
this agent's messaging system, for use in creating a new Conversation. |
java.lang.String |
getConversationPolicyRepository()
Returns the the directory for locating cpXML files and the graph-layouts used in
displaying them
|
void |
init()
Initializes this agent. |
void |
process()
Does one step of processing. |
void |
receiveMessageMethod(javax.agent.TransportMessage msg)
Receives a message. |
void |
setConversationPolicyRepository(java.lang.String repositoryDirectory)
Sets the directory for locating cpXML files and the graph-layouts used in displaying
them. |
Methods inherited from class com.ibm.able.platform.AblePlatformDefaultAgent |
_init, _init, _quitAll, _reset, _resumeAll, _suspendAll, addAgentInbox, addJasAgentAttribute, broadcastTransportMessage, Copyright, createLocatorAndBindToMethod, getAgentAutonomyLevel, getAgentInboxes, getAgentLastUpdate, getAgentStatus, getAgentSummary, getAgentType, getAgentVendor, getAgentVersion, getAndSetAgentDescription, getAndSetAgentNames, getAndSetTransportServices, getAndValidateServiceRoot, getJasAgentAttributes, getJasAgentName, getNewAgentDescription, getPrincipal, getTransportMessageContent, getTransportMessageContent2, init, initializeAgent, initializeAgent, isAgentMovable, isAgentToAutoRegister, isAgentToBindToRmi, loadAgentDescriptionWithAbleAttributes, loadAgentDescriptionWithAbleLocator, loadAgentDescriptionWithAgentName, loadAgentDescriptionWithBaseLocators, loadAgentDescriptionWithPublicKey, loadAgentDescriptionWithUserAttributes, logException, lookUpAgent, lookUpAgent, main, maybeDeregisterWithAgentDirectoryService, maybeRebindToRmi, maybeRegisterWithAgentDirectoryService, maybeUnbindFromRmi, preInit, process, quitAgent, quitAll, receiveMessage, removeAgentInbox, removeAgentInboxes, removeJasAgentAttribute, reset, resetAgent, resumeAgent, resumeAll, sendTransportMessage, sendTransportMessage, setAgentAutonomyLevel, setAgentAutonomyLevel, setAgentMovable, setAgentSummary, setAgentToAutoRegister, setAgentToBindToRmi, setAgentType, setAgentVendor, setAgentVersion, setPrincipal, setRequestKey, suspendAgent, suspendAll, toString, updateDescriptionWithAgentDirectoryService |
Methods inherited from class com.ibm.able.AbleDefaultAgent |
addBean, addBeans, addEventConnection, addUserDefinedFunction, buildProcessList, clsNm, containsBean, containsBean, containsUserDefinedFunction, debugTrace, generateUniqueName, getBean, getBeans, getDataSource, getNumEpochs, getProcessList, getUserDefinedFunction, getUserDefinedFunctions, handleAbleEvent, invokeUserDefinedFunction, isActiveDataSource, propertyChange, quitEnabledEventProcessing, removeAllBeans, removeAllConnections, removeAllEventConnections, removeBean, removeBean, removeBeans, removeEventConnection, removeUserDefinedFunction, setActiveDataSource, setDataFlowEnabled, setProcessList, setUserDefinedFunctions |
Methods inherited from class com.ibm.able.AbleObject |
addAbleEventListener, addDestBufferConnection, addPropertyChangeListener, addPropertyConnection, addSourceBufferConnection, addStateChangeListener, dataChanged, firePropertyChange, flushAbleEventQueue, getAbleEventListeners, getAbleEventProcessingEnabled, getAbleEventQueueSize, getComment, getDestBufferConnections, getFileName, getInputBuffer, getInputBuffer, getInputBufferAsStringArray, getInputBufferContents, getLogger, getName, getOutputBuffer, getOutputBuffer, getOutputBufferAsStringArray, getOutputBufferContents, getParent, getPropertyConnectionManager, getSleepTime, getSourceBufferConnections, getState, getTraceLogger, hasInputBuffer, hasOutputBuffer, isAbleEventPostingEnabled, isAbleEventProcessingEnabled, isChanged, isConnectable, isDataFlowEnabled, isTimerEventProcessingEnabled, notifyAbleEventListeners, processAbleEvent, processBufferConnections, processNoEventProcessingEnabledSituation, processTimerEvent, removeAbleEventListener, removeAllAbleEventListeners, removeAllBufferConnections, removeAllPropertyConnections, removeDestBufferConnection, removePropertyChangeListener, removePropertyConnection, removeSourceBufferConnection, removeStateChangeListener, restartEnabledEventProcessing, restoreFromFile, restoreFromFile, restoreFromSerializedFile, restoreFromStream, resumeEnabledEventProcessing, saveToFile, saveToFile, setAbleEventProcessingEnabled, setChanged, setComment, setFileName, setInputBuffer, setInputBuffer, setLogger, setName, setOutputBuffer, setOutputBuffer, setParent, setSleepTime, setState, setTimerEventProcessingEnabled, setTraceLogger, sourceConnectionsOK, startEnabledEventProcessing, suspendEnabledEventProcessing |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface com.ibm.able.AbleEventQueueRemoteManager |
flushAbleEventQueue, getAbleEventProcessingEnabled, getAbleEventQueueSize, getSleepTime, isTimerEventProcessingEnabled, quitEnabledEventProcessing, restartEnabledEventProcessing, resumeEnabledEventProcessing, setAbleEventProcessingEnabled, setSleepTime, setTimerEventProcessingEnabled, startEnabledEventProcessing, suspendEnabledEventProcessing |
Methods inherited from interface javax.agent.service.transport.MessageListener |
equals, hashCode |
Methods inherited from interface com.ibm.able.AbleBean |
getComment, getLogger, getName, getParent, getState, getTraceLogger, isChanged, setChanged, setComment, setLogger, setName, setParent, setState, setTraceLogger |
Methods inherited from interface com.ibm.able.AbleDataBufferManager |
addDestBufferConnection, addSourceBufferConnection, getDestBufferConnections, getInputBuffer, getInputBuffer, getInputBufferAsStringArray, getInputBufferContents, getOutputBuffer, getOutputBuffer, getOutputBufferAsStringArray, getOutputBufferContents, getSourceBufferConnections, hasInputBuffer, hasOutputBuffer, isConnectable, isDataFlowEnabled, processBufferConnections, removeAllBufferConnections, removeDestBufferConnection, removeSourceBufferConnection, setInputBuffer, setInputBuffer, setOutputBuffer, setOutputBuffer |
Methods inherited from interface com.ibm.able.AbleEventQueueManager |
flushAbleEventQueue, getAbleEventProcessingEnabled, getAbleEventQueueSize, getSleepTime, isAbleEventPostingEnabled, isAbleEventProcessingEnabled, isTimerEventProcessingEnabled, restartEnabledEventProcessing, resumeEnabledEventProcessing, setAbleEventProcessingEnabled, setSleepTime, setTimerEventProcessingEnabled, startEnabledEventProcessing, suspendEnabledEventProcessing |
serialVersionUID
protected static final long serialVersionUID
- Serialized version identifier in form YYYYMMDDVerRelModxx
messageSystemAdapter
protected AbleJasMessageSystemAdapter messageSystemAdapter
- The message-system adapter used in all this agent's outbound JAS messages.
conversationManager
protected AbleConversationManager conversationManager
- The manager for this agent's conversations.
decisionLogicAdapter
protected AbleRemoteUdfDecisionLogicAdapter decisionLogicAdapter
- The decision logic adapter for all of this agent's conversations.
AblePlatformConversationAgent
public AblePlatformConversationAgent()
throws java.rmi.RemoteException,
AbleException
- Constructs an AblePlatformConversationAgent object.
setConversationPolicyRepository
public void setConversationPolicyRepository(java.lang.String repositoryDirectory)
- Sets the directory for locating cpXML files and the graph-layouts used in displaying
them.
- Parameters:
repositoryDirectory
- the path for the directory
getConversationPolicyRepository
public java.lang.String getConversationPolicyRepository()
- Returns the the directory for locating cpXML files and the graph-layouts used in
displaying them
- Returns:
- The repository directory path.
receiveMessageMethod
public void receiveMessageMethod(javax.agent.TransportMessage msg)
- Receives a message.
This is the endpoint for all messages coming in through the JAS transport service.
Routing of the messages to the appropriate Conversation is done based on the
conversation ID in the message envelope. If there is no conversation ID, a new
Conversation is created, to which it is sent.
- Parameters:
msg
- the message received
createMetaData
protected ConversationMetaData createMetaData()
- Creates and returns a ConversationMetaData object compatible with
this agent's messaging system, for use in creating a new Conversation.
Initializes the self-related parts of it, except for the conversation
ID (which is set by the ConversationManager when the conversation is
created).
init
public void init()
throws AbleException
- Initializes this agent.
Sets up a default message inbox;
calls super.init()
;
installs the MessageTransportService (created in super.init()
) in its
MessageSystemAdapter;
initializes its ConversationManager.
- Overrides:
init
in class AblePlatformDefaultAgent
- Following copied from class:
com.ibm.able.platform.AblePlatformDefaultAgent
- Throws:
AbleException
- On any error.
process
public void process()
throws AbleException
- Does one step of processing.
Calls super.process()
, then calls process()
on its
ConversationManager.
- Overrides:
process
in class AbleDefaultAgent
- Following copied from interface:
com.ibm.able.AbleRemoteBean
- Throws:
java.rmi.RemoteException
- If an error occurs.
(C) Copyright IBM Corporation 1999, 2003