public class EntMicService extends MicService
interDDACTION, ACTION_EJB_LOCAL_REF_KEY, ACTION_EJB_REF_KEY, ACTIONADD, ACTIONADDUPDATE, ACTIONDELETE, ACTIONREPLACE, ACTIONUPDATE, ADD, APPEXPORT, AXISDIR, BYPASS, COMMA_CHAR, COMPLETE, DATATYPE, DELETED, EJB_JNDI_KEY, ENABLEPOLLING, ENTERPRISE_EJB_LOCAL_REF_KEY, ENTERPRISE_EJB_REF_KEY, ERREXTRACT, ERROR, ERRORED, ERRORMESSAGETAG, ERTAG, EXCLUDE, EXTRACT, FILEDIR, FILEEXTENSION, FILENAME, FLAT_DATA, FLAT_ROW, FLATFILESEP, FLATFILETYPE, IFACEDRIVER, IFACEEPDESC, IFACEISREMOTE, IFACEPASSWORD, IFACETABLE, IFACEURL, IFACEUSERNAME, INCLUDE, INTEGRATION_LOGGER, IRTAG, ISCONTINUOUS, JMSRECOVERYDIR, JMSRECOVERYMSGDATAELEMENT, JMSRECOVERYMSGPROPELEMENT, JMSRECOVERYTOPELEMENT, JSONFILETYPE, LOADFLAT, LOADXML, LONGDESCRIPTIONCOLNAME, MAX_AUTH_HEADER, MAX_POST_SIZE, MAXIMO_TYPE, MEA_PROCESS_FLAG, MEAAPPNAME, MESSAGE_DESTINATION, MESSAGE_INTERFACE, MESSAGE_INTERFACE_TABLE, MESSAGE_INTERFACE_TYPE, MESSAGE_OS_NAME, MESSAGE_POLL_TABLE, MESSAGE_SENDER, MOS_EJB_LOCAL_REF_KEY, MOS_EJB_REF_KEY, MSG_ERR_MSG, MSG_KEY_VAL, MSG_OP_MODE, MSG_OPERATION, MSG_STATUS, MSG_TRK_ENABLED, MSG_TRK_EXTSYS, MSG_TRK_STORE_MSG, MXJMS, NONPERSISTENT, NONRESTRICTSETTING, NULL, POLLINGFREQUENCY, PROCESS, PROCESSED, QUEUE_NAME, QUEUECONTEXT, RECEIVED, REJECTED, RESTRICTSETTING, RESTRICTSTRUCTURE, ROOT_NODE, ROUTER_JNDI_NAME, SEARCH_FIELD_VAL, SKIP, SKIPMBO, sNo, sYes, TENANTID, TEXTQUALIFIER, TOPTAGFORERR, TOTAL_GL_COMPS_ALLOWED, TRANSIDSEQ, TXNDATA, UPDATE, USER, USERCOLUMN, VIEW, XML_DATA, XMLFILETYPE, XMLTYPEAPPLOGGER, CRONTASKLOGGER, CRONTASKMGRLOGGER, CRONTASKMGRSQLLOGGER, DBCONNECTIONLOGGER, DDLOGGER, DMLOGGER, EVENTLOGGER, EXCEPTIONLOGGER, MAILLOGGER, MAXIMOLOGGER, MTLOGGER, NULLMBOPOINTER, SECURITY, SENDFAILEDLOGGER, SERVICELOGGER, SQLLOGGERappenderPrefix, LOGGERNAME_APP, LOGGERNAME_CRONTASK, LOGGERNAME_CRONTASKMGR, LOGGERNAME_DBCONNECTION, LOGGERNAME_DD, LOGGERNAME_DM, LOGGERNAME_DMPREVIEW, LOGGERNAME_EVENT, LOGGERNAME_EXCEPTION, LOGGERNAME_MAIL, LOGGERNAME_MAXIMO, LOGGERNAME_MT, LOGGERNAME_NULLMBOPOINTER, LOGGERNAME_SECURITY, LOGGERNAME_SENDFAILED, LOGGERNAME_SERVICE, LOGGERNAME_SQL, LOGGERNAME_SQL_CRONTASKMGR, LOGGERNAME_TXN, loggerPrefix| Constructor and Description |
|---|
EntMicService()
Construct the service
|
EntMicService(MXServer mxServer) |
| Modifier and Type | Method and Description |
|---|---|
byte[] |
bidiTransformData(java.util.Map<java.lang.String,?> metaData,
byte[] data)
Return data using bidi conversion
|
boolean |
checkStatus(StructureData irData,
java.lang.String extSystem,
java.lang.String sendListName,
java.lang.String orgId,
java.lang.String siteId,
boolean sendUpdates)
This method checks status and does the following.
|
void |
configure(java.util.Properties configData)
Configure the AppService.
|
void |
deleteErrorFileAndTableRow(java.util.Map<java.lang.String,java.lang.String> propMap,
boolean inbound,
java.lang.String queueName,
UserInfo userInfo)
Delete the message entry in the error tracking tables.
|
int |
deleteQueueData(java.lang.String queueName,
java.lang.String selector,
int count,
UserInfo userInfo)
Delete the messages in a JMS queue based on selectors and the count
|
void |
exportData(java.lang.String ifaceName,
java.lang.String sender,
java.lang.String where,
java.lang.String orderBy,
int pageSize,
UserInfo userInfo,
int maxcount)
This method will be called from GUI for bulk data loading from MAXIMO to
external system
|
void |
exportData(java.lang.String ifaceName,
java.lang.String sender,
java.lang.String where,
UserInfo userInfo,
int maxcount)
This method will be called from GUI for bulk data loading from MAXIMO to
external system
|
byte[] |
getBidiData(byte[] responseBody,
java.lang.String bidiFormat)
Return data using bidi conversion
|
java.lang.String |
getEndPointName(java.lang.String extSysName,
java.lang.String pubChannelName)
Get end point name for external system and publish channel.
|
UserInfo |
getIfaceTableUserInfo()
Returns user info for interface tables
|
java.lang.String |
getLaunchURL(java.lang.String launchEntryName,
MboRemote mainMbo)
Get Object Structure name base on entity name of the interface table.
|
java.lang.String |
getMosNameForPubChannel(java.lang.String channelName)
Get object structure name for publish channel.
|
java.lang.String |
getNormalizedName(java.lang.String queueName)
Get normalized queue name.
|
java.lang.String |
getOSNameForIfaceTable(java.lang.String entityName)
Get Object Structure name base on entity name of the interface table.
|
java.lang.String |
getQueueToWrite()
Get notification queue name.
|
java.lang.String[] |
getTargetWindow(java.lang.String launchEntryName,
MboRemote mainMbo)
Get Target Window.
|
void |
init()
Init method
|
byte[] |
internalProcessExternalData(byte[] data,
java.lang.String sender,
java.lang.String ifaceName,
UserInfo info,
MXTransaction trans)
Internal method for Unit Test.
|
void |
invokeChannel(java.lang.String channelName,
MboRemote mbo)
Invoke Invocation Channel.
|
void |
loadSystemData(java.lang.String directory,
java.lang.String intLevel,
UserInfo userInfo)
Process system data comimg in Maximo format.
|
java.util.List<java.lang.String> |
populateQueueList(java.util.HashSet<java.lang.String> validateAgainst,
java.lang.String nqDescription)
Populate JMS queues entries.
|
byte[] |
processDataIn(StructureData irData,
EnterpriseServiceInfo detailInfo,
java.lang.String extSystem,
UserInfo info,
MXTransaction mxTrans)
This method will be called for every object structure to process
External data.
|
byte[] |
processExternalData(byte[] data,
java.lang.String sender,
java.lang.String ifaceName,
UserInfo info,
MXTransaction trans)
Process data comimg from external system.
|
byte[] |
processExternalData(byte[] data,
java.lang.String sender,
java.lang.String ifaceName,
UserInfo userInfo,
MXTransaction trans,
boolean fromQueue)
Process data comimg from external system.
|
void |
processJMSRecovery(java.lang.String queueName,
UserInfo userInfo)
JMS recovery logic
|
byte[] |
query(byte[] data,
java.lang.String serviceName,
java.lang.String extSystem,
UserInfo userInfo)
Query maximo via query query services.
|
byte[] |
query(byte[] queryXml,
java.lang.String mosName,
UserInfo userInfo)
Query maximo via query objec structure service.
|
byte[] |
query(org.jdom.Document data,
java.lang.String serviceName,
java.lang.String extSystem,
UserInfo userInfo)
Query maximo via query query services.
|
byte[] |
query(org.jdom.Document queryXml,
java.lang.String mosName,
UserInfo userInfo)
Query maximo via query objec structure service.
|
void |
setIfaceTableUserInfo(UserInfo info)
Sets user info for interface table processing
|
void |
tryObjectStructure(java.lang.String mosName,
java.lang.String where,
UserInfo userInfo) |
void |
viewQueueData(java.lang.String queueName,
java.lang.String selector,
int count,
UserInfo userInfo)
Dumps all the messages in the JMS queue into a preconfigured folder.
|
int |
viewQueueData(java.lang.String queueName,
java.lang.String selector,
int count,
UserInfo userInfo,
boolean countOnly) |
int |
viewQueueData(java.lang.String queueName,
java.lang.String selector,
int count,
UserInfo userInfo,
boolean countOnly,
java.util.List<java.lang.String> viewFilesList) |
void |
viewQueueDataApi(java.lang.String queueName,
java.lang.String selector,
int count,
UserInfo userInfo) |
void |
writeDataToNotificationQueue(MXTransaction mxtran,
java.lang.String eventForUser,
java.util.Map<java.lang.String,java.lang.String> properties,
UserInfo userInfo,
byte[] queueData,
java.lang.String textData,
boolean syntheticEvent)
Write notification to the queue.
|
void |
wsinteraction(java.lang.String interactionName,
MboRemote mbo)
Process Web Service Interaction.
|
callIntegrityChecker, generateMOSServiceSchema, getIntegrationDD, getMEAProperty, getMicServiceInitDone, getMicSetInfo, getMonitorUserInfo, getNewUserInfo, getObjectStructureInfo, getPrimaryInfo, getRowStampMap, internalProcessData, loadData, processObjectStructureService, processObjectStructureService, processOSLC, processOSLCAsJSON, processOSLCAsJSON, processOSLCJSON, refreshIntegrationDD, resetWorkscapelayoutCards, routeData, validateFormulacheckSecurity, destroy, freeDBConnection, freeMboSet, getCriteria, getCurrentState, getDBConnection, getLiveObjCount, getLoad, getMaximoDD, getMaxVar, getMboSet, getMXServer, getName, getProfile, getProxy, getSchemaOwner, getServiceInfo, getServiceLogger, getSetForRelationship, getSetFromKeys, getStateCmdList, getStateList, getURL, initCriteriaList, isAppService, isRunning, isSingletonService, restart, setProxy, setRunning, setURL, verifyUser, verifyUserequals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitrestartcheckSecurity, getCriteria, getCurrentState, getLiveObjCount, getMboSet, getName, getSchemaOwner, getSetForRelationship, getSetFromKeys, getStateCmdList, getStateList, getURL, verifyUser, verifyUserisAppService, isSingletonServicepublic EntMicService()
throws java.rmi.RemoteException
java.rmi.RemoteExceptionpublic EntMicService(MXServer mxServer) throws java.rmi.RemoteException
mxServer - The "Server Environment" this Service is being created in.java.rmi.RemoteExceptionpublic void configure(java.util.Properties configData)
configure in interface Serviceconfigure in class MicServiceServicepublic void init()
init in interface Serviceinit in class MicServiceServicepublic byte[] query(byte[] data,
java.lang.String serviceName,
java.lang.String extSystem,
UserInfo userInfo)
throws MXException,
java.rmi.RemoteException
query in interface MicServiceRemotequery in class MicServicedata - the query xml in byte[] formatserviceName - name of the serviceextSystem - name of the external systemuserInfo - the UserInfo for user detailsjava.rmi.RemoteExceptionMXExceptionpublic byte[] query(org.jdom.Document data,
java.lang.String serviceName,
java.lang.String extSystem,
UserInfo userInfo)
throws MXException,
java.rmi.RemoteException
query in class MicServicedata - the query xml in byte[] formatserviceName - name of the serviceextSystem - name of the external systemuserInfo - the UserInfo for user detailsjava.rmi.RemoteExceptionMXExceptionpublic byte[] query(byte[] queryXml,
java.lang.String mosName,
UserInfo userInfo)
throws MXException,
java.rmi.RemoteException
query in interface MicServiceRemotequery in class MicServicequeryXml - the query xmlmosName - the object structure nameuserInfo - the UserInfo for user detailsjava.rmi.RemoteExceptionMXExceptionpublic byte[] query(org.jdom.Document queryXml,
java.lang.String mosName,
UserInfo userInfo)
throws MXException,
java.rmi.RemoteException
query in class MicServicequeryXml - the query xmlmosName - the object structure nameuserInfo - the UserInfo for user detailsjava.rmi.RemoteExceptionMXExceptionpublic int deleteQueueData(java.lang.String queueName,
java.lang.String selector,
int count,
UserInfo userInfo)
throws java.rmi.RemoteException,
MXException
deleteQueueData in interface MicServiceRemotedeleteQueueData in class MicServicequeueName - the JNDI name of the queueselector - the messages selector [where clause].count - the count of messages to be deleted. A value of -1 indicates
delete all messages.userInfo - the user details for security validationjava.rmi.RemoteException - Remote exceptionMXException - MAXIMO exceptionpublic void tryObjectStructure(java.lang.String mosName,
java.lang.String where,
UserInfo userInfo)
throws MXException,
java.rmi.RemoteException
tryObjectStructure in interface MicServiceRemotetryObjectStructure in class MicServiceMXExceptionjava.rmi.RemoteExceptionpublic void deleteErrorFileAndTableRow(java.util.Map<java.lang.String,java.lang.String> propMap,
boolean inbound,
java.lang.String queueName,
UserInfo userInfo)
throws MXException,
java.rmi.RemoteException
deleteErrorFileAndTableRow in class MicServicepropMap - the message propertiesinbound - true for inbound and false for outbound queuesqueueName - the jndi name of the queueuserInfo - the authenticated userMXExceptionjava.rmi.RemoteExceptionpublic void processJMSRecovery(java.lang.String queueName,
UserInfo userInfo)
throws java.rmi.RemoteException,
MXException
processJMSRecovery in interface MicServiceRemoteprocessJMSRecovery in class MicServicequeueName - the JNDI name of the queueuserInfo - the user details for security validationjava.rmi.RemoteExceptionMXExceptionpublic int viewQueueData(java.lang.String queueName,
java.lang.String selector,
int count,
UserInfo userInfo,
boolean countOnly)
throws java.rmi.RemoteException,
MXException
viewQueueData in interface MicServiceRemoteviewQueueData in class MicServicequeueName - the name of the queueselector - the selector clausecount - the max number of rows to be vieweduserInfo - the authenticated userInfocountOnly - true implies the viewd messages would not be written to a
folder and false otherwise. Note in either case all the messages would be viewed
from the queue - so in case the number of viewed messages is large it will effect the
performance in either case.java.rmi.RemoteExceptionMXExceptionpublic void viewQueueDataApi(java.lang.String queueName,
java.lang.String selector,
int count,
UserInfo userInfo)
throws java.rmi.RemoteException,
MXException
java.rmi.RemoteExceptionMXExceptionpublic int viewQueueData(java.lang.String queueName,
java.lang.String selector,
int count,
UserInfo userInfo,
boolean countOnly,
java.util.List<java.lang.String> viewFilesList)
throws java.rmi.RemoteException,
MXException
viewQueueData in interface MicServiceRemoteviewQueueData in class MicServicequeueName - the name of the queueselector - the selector clausecount - the max number of rows to be vieweduserInfo - the authenticated userInfocountOnly - true implies the viewd messages would not be written to a
folder and false otherwise. Note in either case all the messages would be viewed
from the queue - so in case the number of viewed messages is large it will effect the
performance in either case.viewFilesList - List of file names [absolute location] of messages that were viewed.java.rmi.RemoteExceptionMXExceptionpublic void viewQueueData(java.lang.String queueName,
java.lang.String selector,
int count,
UserInfo userInfo)
throws java.rmi.RemoteException,
MXException
viewQueueData in interface MicServiceRemoteviewQueueData in class MicServicequeueName - the JNDI name of the queueselector - the messages selector [where clause].count - the count of messages to be viewed. A value of -1 indicates
delete all messages.userInfo - the user details for security validationjava.rmi.RemoteException - Remote exceptionMXException - MAXIMO exceptionpublic void setIfaceTableUserInfo(UserInfo info)
info - userInfo objectpublic UserInfo getIfaceTableUserInfo() throws MXException, java.rmi.RemoteException
MXExceptionjava.rmi.RemoteExceptionpublic void exportData(java.lang.String ifaceName,
java.lang.String sender,
java.lang.String where,
UserInfo userInfo,
int maxcount)
throws MXException,
java.rmi.RemoteException
exportData in interface MicServiceRemoteexportData in class MicServiceifaceName - Give name of channel.sender - Give external system name.where - Give where clause.userInfo - Give reference to UserInfo object.maxcount - maximum count to get.MXException - MAXIMO exceptionjava.rmi.RemoteException - Remote exceptionpublic void exportData(java.lang.String ifaceName,
java.lang.String sender,
java.lang.String where,
java.lang.String orderBy,
int pageSize,
UserInfo userInfo,
int maxcount)
throws MXException,
java.rmi.RemoteException
exportData in class MicServiceifaceName - Give name of channel.sender - Give external system name.where - Give where clause.userInfo - Give reference to UserInfo object.MXException - MAXIMO exceptionjava.rmi.RemoteException - Remote exceptionpublic void loadSystemData(java.lang.String directory,
java.lang.String intLevel,
UserInfo userInfo)
throws MXException,
java.rmi.RemoteException
loadSystemData in interface MicServiceRemoteloadSystemData in class MicServicedirectory - Give directory where load files areintLevel - Lervel of processing.userInfo - the user details for security validationMXException - MAXIMO exceptionjava.rmi.RemoteException - Remote exceptionpublic byte[] processExternalData(byte[] data,
java.lang.String sender,
java.lang.String ifaceName,
UserInfo info,
MXTransaction trans)
throws MXException,
java.rmi.RemoteException
processExternalData in interface MicServiceRemoteprocessExternalData in class MicServicedata - Give data as byte arraysender - Give sender name.ifaceName - Give name of interface.info - Give reference to UserInfo object.trans - Give MXTransaction object.MXException - MAXIMO exceptionjava.rmi.RemoteException - Remote exceptionpublic byte[] processExternalData(byte[] data,
java.lang.String sender,
java.lang.String ifaceName,
UserInfo userInfo,
MXTransaction trans,
boolean fromQueue)
throws MXException,
java.rmi.RemoteException
processExternalData in class MicServicedata - Give data as byte arraysender - Give sender name.ifaceName - Give name of service.userInfo - Give reference to UserInfo object.trans - Give MXTransaction object.fromQueue - Give indicator for data coming from queue.MXException - MAXIMO exceptionjava.rmi.RemoteException - Remote exceptionpublic byte[] processDataIn(StructureData irData, EnterpriseServiceInfo detailInfo, java.lang.String extSystem, UserInfo info, MXTransaction mxTrans) throws MXException, java.rmi.RemoteException
irData - Give reference to StructureData objectdetailInfo - Give information about enterprise service.extSystem - Give name of External System.info - Give reference to UserInfo object.mxTrans - Give MXTransaction object.MXException - MAXIMO exceptionjava.rmi.RemoteException - Remote exceptionpublic byte[] internalProcessExternalData(byte[] data,
java.lang.String sender,
java.lang.String ifaceName,
UserInfo info,
MXTransaction trans)
throws MXException,
java.rmi.RemoteException
internalProcessExternalData in class MicServicedata - Give data as byte arraysender - Give sender name.ifaceName - Give name of interface.info - Give reference to UserInfo object.trans - Give MXTransaction object.MXException - MAXIMO exceptionjava.rmi.RemoteException - Remote exceptionpublic java.lang.String getOSNameForIfaceTable(java.lang.String entityName)
throws java.rmi.RemoteException,
MXException
getOSNameForIfaceTable in class MicServiceentityName - entity nameMXExceptionjava.rmi.RemoteExceptionpublic java.util.List<java.lang.String> populateQueueList(java.util.HashSet<java.lang.String> validateAgainst,
java.lang.String nqDescription)
throws java.rmi.RemoteException
populateQueueList in class MicServicevalidateAgainst - set of valuesnqDescription - queue descriptionjava.rmi.RemoteExceptionpublic java.lang.String[] getTargetWindow(java.lang.String launchEntryName,
MboRemote mainMbo)
throws java.rmi.RemoteException,
MXException
getTargetWindow in class MicServicelaunchEntryName - launch entry namemainMbo - main mbo referenceMXExceptionjava.rmi.RemoteExceptionpublic void invokeChannel(java.lang.String channelName,
MboRemote mbo)
throws MXException,
java.rmi.RemoteException
invokeChannel in class MicServicechannelName - invoke channel namembo - mbo referenceMXExceptionjava.rmi.RemoteExceptionpublic void wsinteraction(java.lang.String interactionName,
MboRemote mbo)
throws java.rmi.RemoteException,
MXException
wsinteraction in class MicServiceinteractionName - interaction namembo - mbo referenceMXExceptionjava.rmi.RemoteExceptionpublic byte[] bidiTransformData(java.util.Map<java.lang.String,?> metaData,
byte[] data)
throws MXException
bidiTransformData in class MicServiceMXExceptionpublic java.lang.String getEndPointName(java.lang.String extSysName,
java.lang.String pubChannelName)
throws java.rmi.RemoteException,
MXException
getEndPointName in class MicServiceextSysName - external system namepubChannelName - publish channel nameMXExceptionjava.rmi.RemoteExceptionpublic java.lang.String getQueueToWrite()
throws MXException
getQueueToWrite in class MicServiceMXExceptionpublic void writeDataToNotificationQueue(MXTransaction mxtran, java.lang.String eventForUser, java.util.Map<java.lang.String,java.lang.String> properties, UserInfo userInfo, byte[] queueData, java.lang.String textData, boolean syntheticEvent) throws MXException
writeDataToNotificationQueue in class MicServicemxtran - Maximo transactioneventForUser - user nameproperties - map of queue propertiesuserInfo - user infoqueueData - queue datatextData - text datasyntheticEvent - synthetic eventMXExceptionpublic java.lang.String getNormalizedName(java.lang.String queueName)
throws MXException
getNormalizedName in class MicServicequeueName - queue nameMXExceptionpublic java.lang.String getMosNameForPubChannel(java.lang.String channelName)
throws MXException
getMosNameForPubChannel in class MicServicechannelName - publish channel nameMXExceptionpublic byte[] getBidiData(byte[] responseBody,
java.lang.String bidiFormat)
throws MXException
getBidiData in class MicServiceMXExceptionpublic java.lang.String getLaunchURL(java.lang.String launchEntryName,
MboRemote mainMbo)
throws java.rmi.RemoteException,
MXException
getLaunchURL in class MicServiceentityName - entity nameMXExceptionjava.rmi.RemoteExceptionpublic boolean checkStatus(StructureData irData, java.lang.String extSystem, java.lang.String sendListName, java.lang.String orgId, java.lang.String siteId, boolean sendUpdates) throws MXException, java.rmi.RemoteException
checkStatus in class MicServiceirData - StructureData for IR.extSystem - Name of the External System.sendListName - Name of the XXSEND list.orgId - orgId for the list controlsiteId - siteId for the list controlsendUpdates - indicator to send updatesMXExceptionjava.rmi.RemoteException