public class EntMicService extends MicService
interDD
ACTION, 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, XMLTYPE
APPLOGGER, CRONTASKLOGGER, CRONTASKMGRLOGGER, CRONTASKMGRSQLLOGGER, DBCONNECTIONLOGGER, DDLOGGER, DMLOGGER, EVENTLOGGER, EXCEPTIONLOGGER, MAILLOGGER, MAXIMOLOGGER, MTLOGGER, NULLMBOPOINTER, SECURITY, SENDFAILEDLOGGER, SERVICELOGGER, SQLLOGGER
appenderPrefix, 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, validateFormula
checkSecurity, 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, verifyUser
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
restart
checkSecurity, getCriteria, getCurrentState, getLiveObjCount, getMboSet, getName, getSchemaOwner, getSetForRelationship, getSetFromKeys, getStateCmdList, getStateList, getURL, verifyUser, verifyUser
isAppService, isSingletonService
public EntMicService() throws java.rmi.RemoteException
java.rmi.RemoteException
public EntMicService(MXServer mxServer) throws java.rmi.RemoteException
mxServer
- The "Server Environment" this Service is being created in.java.rmi.RemoteException
public void configure(java.util.Properties configData)
configure
in interface Service
configure
in class MicService
Service
public void init()
init
in interface Service
init
in class MicService
Service
public byte[] query(byte[] data, java.lang.String serviceName, java.lang.String extSystem, UserInfo userInfo) throws MXException, java.rmi.RemoteException
query
in interface MicServiceRemote
query
in class MicService
data
- the query xml in byte[] formatserviceName
- name of the serviceextSystem
- name of the external systemuserInfo
- the UserInfo for user detailsjava.rmi.RemoteException
MXException
public byte[] query(org.jdom.Document data, java.lang.String serviceName, java.lang.String extSystem, UserInfo userInfo) throws MXException, java.rmi.RemoteException
query
in class MicService
data
- the query xml in byte[] formatserviceName
- name of the serviceextSystem
- name of the external systemuserInfo
- the UserInfo for user detailsjava.rmi.RemoteException
MXException
public byte[] query(byte[] queryXml, java.lang.String mosName, UserInfo userInfo) throws MXException, java.rmi.RemoteException
query
in interface MicServiceRemote
query
in class MicService
queryXml
- the query xmlmosName
- the object structure nameuserInfo
- the UserInfo for user detailsjava.rmi.RemoteException
MXException
public byte[] query(org.jdom.Document queryXml, java.lang.String mosName, UserInfo userInfo) throws MXException, java.rmi.RemoteException
query
in class MicService
queryXml
- the query xmlmosName
- the object structure nameuserInfo
- the UserInfo for user detailsjava.rmi.RemoteException
MXException
public int deleteQueueData(java.lang.String queueName, java.lang.String selector, int count, UserInfo userInfo) throws java.rmi.RemoteException, MXException
deleteQueueData
in interface MicServiceRemote
deleteQueueData
in class MicService
queueName
- 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 MicServiceRemote
tryObjectStructure
in class MicService
MXException
java.rmi.RemoteException
public 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 MicService
propMap
- the message propertiesinbound
- true for inbound and false for outbound queuesqueueName
- the jndi name of the queueuserInfo
- the authenticated userMXException
java.rmi.RemoteException
public void processJMSRecovery(java.lang.String queueName, UserInfo userInfo) throws java.rmi.RemoteException, MXException
processJMSRecovery
in interface MicServiceRemote
processJMSRecovery
in class MicService
queueName
- the JNDI name of the queueuserInfo
- the user details for security validationjava.rmi.RemoteException
MXException
public int viewQueueData(java.lang.String queueName, java.lang.String selector, int count, UserInfo userInfo, boolean countOnly) throws java.rmi.RemoteException, MXException
viewQueueData
in interface MicServiceRemote
viewQueueData
in class MicService
queueName
- 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.RemoteException
MXException
public void viewQueueDataApi(java.lang.String queueName, java.lang.String selector, int count, UserInfo userInfo) throws java.rmi.RemoteException, MXException
java.rmi.RemoteException
MXException
public 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 MicServiceRemote
viewQueueData
in class MicService
queueName
- 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.RemoteException
MXException
public void viewQueueData(java.lang.String queueName, java.lang.String selector, int count, UserInfo userInfo) throws java.rmi.RemoteException, MXException
viewQueueData
in interface MicServiceRemote
viewQueueData
in class MicService
queueName
- 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
MXException
java.rmi.RemoteException
public 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 MicServiceRemote
exportData
in class MicService
ifaceName
- 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 MicService
ifaceName
- 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 MicServiceRemote
loadSystemData
in class MicService
directory
- 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 MicServiceRemote
processExternalData
in class MicService
data
- 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 MicService
data
- 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 MicService
data
- 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 MicService
entityName
- entity nameMXException
java.rmi.RemoteException
public 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 MicService
validateAgainst
- set of valuesnqDescription
- queue descriptionjava.rmi.RemoteException
public java.lang.String[] getTargetWindow(java.lang.String launchEntryName, MboRemote mainMbo) throws java.rmi.RemoteException, MXException
getTargetWindow
in class MicService
launchEntryName
- launch entry namemainMbo
- main mbo referenceMXException
java.rmi.RemoteException
public void invokeChannel(java.lang.String channelName, MboRemote mbo) throws MXException, java.rmi.RemoteException
invokeChannel
in class MicService
channelName
- invoke channel namembo
- mbo referenceMXException
java.rmi.RemoteException
public void wsinteraction(java.lang.String interactionName, MboRemote mbo) throws java.rmi.RemoteException, MXException
wsinteraction
in class MicService
interactionName
- interaction namembo
- mbo referenceMXException
java.rmi.RemoteException
public byte[] bidiTransformData(java.util.Map<java.lang.String,?> metaData, byte[] data) throws MXException
bidiTransformData
in class MicService
MXException
public java.lang.String getEndPointName(java.lang.String extSysName, java.lang.String pubChannelName) throws java.rmi.RemoteException, MXException
getEndPointName
in class MicService
extSysName
- external system namepubChannelName
- publish channel nameMXException
java.rmi.RemoteException
public java.lang.String getQueueToWrite() throws MXException
getQueueToWrite
in class MicService
MXException
public 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 MicService
mxtran
- Maximo transactioneventForUser
- user nameproperties
- map of queue propertiesuserInfo
- user infoqueueData
- queue datatextData
- text datasyntheticEvent
- synthetic eventMXException
public java.lang.String getNormalizedName(java.lang.String queueName) throws MXException
getNormalizedName
in class MicService
queueName
- queue nameMXException
public java.lang.String getMosNameForPubChannel(java.lang.String channelName) throws MXException
getMosNameForPubChannel
in class MicService
channelName
- publish channel nameMXException
public byte[] getBidiData(byte[] responseBody, java.lang.String bidiFormat) throws MXException
getBidiData
in class MicService
MXException
public java.lang.String getLaunchURL(java.lang.String launchEntryName, MboRemote mainMbo) throws java.rmi.RemoteException, MXException
getLaunchURL
in class MicService
entityName
- entity nameMXException
java.rmi.RemoteException
public 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 MicService
irData
- 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 updatesMXException
java.rmi.RemoteException