public class MicService extends AppService implements MicServiceRemote, MicConstants
Modifier and Type | Field and Description |
---|---|
ObjectStructureCache |
interDD
Describes Integration Data Dictinary
|
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, INTEGRATION_LOGGER, IRTAG, ISCONTINUOUS, JMSRECOVERYDIR, JMSRECOVERYMSGDATAELEMENT, JMSRECOVERYMSGPROPELEMENT, JMSRECOVERYTOPELEMENT, 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 |
---|
MicService()
Construct the service
|
MicService(MXServer mxServer) |
Modifier and Type | Method and Description |
---|---|
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,
UserInfo userInfo,
int maxcount)
This method will be called from GUI for bulk data loading from MAXIMO to
external system
|
void |
generateMOSServiceSchema(java.lang.String mosName,
boolean forceGenerate)
generates the Object Structure schema
|
UserInfo |
getIfaceTableUserInfo()
Returns user info for interface tables
|
ObjectStructureCache |
getIntegrationDD()
Get reference to Integration DD.
|
java.lang.String |
getMEAProperty(java.lang.String propertyName)
Utility method to get a MEA property
|
static boolean |
getMicServiceInitDone() |
MicSetInfo |
getMicSetInfo(java.lang.String mosName,
java.lang.String objname)
Deprecated.
|
UserInfo |
getNewUserInfo()
Create new instance of user info for Integration User
|
MosInfo |
getObjectStructureInfo(java.lang.String objectStructureName)
Get MosInfo for a given Object Structure name.
|
MosDetailInfo |
getPrimaryInfo(java.lang.String mosName)
Get the primary MosDetailInfo
|
void |
init()
Init method
|
byte[] |
internalProcessData(byte[] in,
UserInfo info,
MXTransaction trans)
Internal method for Unit Test
This method will be called for every object structure service to process
incoming transactions.
|
byte[] |
internalProcessExternalData(byte[] data,
java.lang.String sender,
java.lang.String ifaceName,
UserInfo info,
MXTransaction trans)
Internal method for Unit Test.
|
byte[] |
loadData(byte[] in,
UserInfo info,
MXTransaction trans,
java.util.Map defaults)
This method will be called to load object structure XML data.
|
void |
loadSystemData(java.lang.String directory,
java.lang.String intLevel,
UserInfo userInfo)
Process system data comimg in Maximo format.
|
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) |
byte[] |
processObjectStructureService(byte[] in,
java.lang.String mosName,
java.lang.String messageType,
UserInfo info,
MXTransaction trans)
This method will be called for every object structure service to process
incoming transactions.
|
byte[] |
processObjectStructureService(org.jdom.Document doc,
java.lang.String mosName,
java.lang.String messageType,
UserInfo info,
MXTransaction trans)
This method will be called for every object structure service to process
incoming transactions.
|
long |
processOSLC(byte[] in,
java.lang.String mosName,
java.lang.String messageType,
UserInfo info,
MXTransaction trans,
MboRemote mbo,
java.lang.String format)
This method will be called for every object structure service to process
incoming transactions.
|
long |
processOSLCJSON(byte[] in,
java.lang.String mosName,
java.lang.String messageType,
UserInfo info,
MXTransaction trans,
MboRemote mbo)
This method will be called for every object structure service to process
incoming transactions.
|
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 |
refreshIntegrationDD()
Refresh ObjectStructureCache.
|
byte[] |
routeData(byte[] data,
java.lang.String endPointName,
java.util.Map<java.lang.String,?> metaData)
Deplyment manager API to Route Data.
|
void |
setIfaceTableUserInfo(UserInfo info)
Sets user info for interface table processing
|
void |
tryObjectStructure(java.lang.String mosName,
java.lang.String where) |
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) |
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 ObjectStructureCache interDD
public MicService() throws java.rmi.RemoteException
java.rmi.RemoteException
public MicService(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 AppService
Service
public void init()
init
in interface Service
init
in class AppService
Service
public MosDetailInfo getPrimaryInfo(java.lang.String mosName) throws java.rmi.RemoteException, MXException
mosName
- the name of the object structurejava.rmi.RemoteException
MXException
public MicSetInfo getMicSetInfo(java.lang.String mosName, java.lang.String objname) throws java.rmi.RemoteException, MXException
mosName
- the name of the integration objectobjname
- the name of the objectjava.rmi.RemoteException
MXException
public byte[] query(byte[] data, java.lang.String serviceName, java.lang.String extSystem, UserInfo userInfo) throws MXException, java.rmi.RemoteException
query
in interface MicServiceRemote
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
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
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
queryXml
- the query xmlmosName
- the object structure nameuserInfo
- the UserInfo for user detailsjava.rmi.RemoteException
MXException
public byte[] routeData(byte[] data, java.lang.String endPointName, java.util.Map<java.lang.String,?> metaData) throws MXException, java.rmi.RemoteException
routeData
in interface MicServiceRemote
data
- byte repersentataion of the dataendPointName
- name of the end pointmetaData
- Map of parametersjava.rmi.RemoteException
MXException
public void tryObjectStructure(java.lang.String mosName, java.lang.String where) throws MXException, java.rmi.RemoteException
tryObjectStructure
in interface MicServiceRemote
MXException
java.rmi.RemoteException
public UserInfo getNewUserInfo() throws MXException, java.rmi.RemoteException
MXException
- MAXIMO exceptionjava.rmi.RemoteException
- Remote exceptionpublic int deleteQueueData(java.lang.String queueName, java.lang.String selector, int count, UserInfo userInfo) throws java.rmi.RemoteException, MXException
deleteQueueData
in interface MicServiceRemote
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 deleteErrorFileAndTableRow(java.util.Map<java.lang.String,java.lang.String> propMap, boolean inbound, java.lang.String queueName, UserInfo userInfo) throws MXException, java.rmi.RemoteException
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
java.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
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 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
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
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 ObjectStructureCache getIntegrationDD()
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
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 loadSystemData(java.lang.String directory, java.lang.String intLevel, UserInfo userInfo) throws MXException, java.rmi.RemoteException
loadSystemData
in interface MicServiceRemote
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
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
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[] processObjectStructureService(byte[] in, java.lang.String mosName, java.lang.String messageType, UserInfo info, MXTransaction trans) throws MXException, java.rmi.RemoteException
processObjectStructureService
in interface MicServiceRemote
in
- Give byteArraymosName
- Give name of object structure.messageType
- Give name of operation.info
- Give reference to UserInfo object.trans
- Give MXTransaction object.MXException
- MAXIMO exceptionjava.rmi.RemoteException
- Remote exceptionpublic long processOSLCJSON(byte[] in, java.lang.String mosName, java.lang.String messageType, UserInfo info, MXTransaction trans, MboRemote mbo) throws MXException, java.rmi.RemoteException
in
- Give byteArraymosName
- Give name of object structure.messageType
- Give name of operation.info
- Give reference to UserInfo object.trans
- Give MXTransaction object.MXException
- MAXIMO exceptionjava.rmi.RemoteException
- Remote exceptionpublic long processOSLC(byte[] in, java.lang.String mosName, java.lang.String messageType, UserInfo info, MXTransaction trans, MboRemote mbo, java.lang.String format) throws MXException, java.rmi.RemoteException
in
- Give byteArraymosName
- Give name of object structure.messageType
- Give name of operation.info
- Give reference to UserInfo object.trans
- Give MXTransaction object.MXException
- MAXIMO exceptionjava.rmi.RemoteException
- Remote exceptionpublic byte[] processObjectStructureService(org.jdom.Document doc, java.lang.String mosName, java.lang.String messageType, UserInfo info, MXTransaction trans) throws MXException, java.rmi.RemoteException
doc
- Give byteArraymosName
- Give name of object structure.messageType
- Give name of operation.info
- Give reference to UserInfo object.trans
- Give MXTransaction object.MXException
- MAXIMO exceptionjava.rmi.RemoteException
- Remote exceptionpublic byte[] loadData(byte[] in, UserInfo info, MXTransaction trans, java.util.Map defaults) throws MXException, java.rmi.RemoteException
loadData
in interface MicServiceRemote
in
- Give byteArrayinfo
- Give reference to UserInfo object.trans
- Give MXTransaction object.defaults
- Map of defult values to skip setting data to Mbo from XML.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
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[] internalProcessData(byte[] in, UserInfo info, MXTransaction trans) throws MXException, java.rmi.RemoteException
in
- Give byteArrayinfo
- Give reference to UserInfo object.trans
- Give MXTransaction object.MXException
- MAXIMO exceptionjava.rmi.RemoteException
- Remote exceptionpublic void refreshIntegrationDD() throws MXException, java.rmi.RemoteException
MXException
java.rmi.RemoteException
public static boolean getMicServiceInitDone()
public java.lang.String getMEAProperty(java.lang.String propertyName) throws java.rmi.RemoteException
propertyName
- the property namejava.rmi.RemoteException
- Remote exceptionpublic void generateMOSServiceSchema(java.lang.String mosName, boolean forceGenerate) throws java.rmi.RemoteException, MXException
generateMOSServiceSchema
in interface MicServiceRemote
mosName
- the Object Structure namejava.rmi.RemoteException
MXException
public MosInfo getObjectStructureInfo(java.lang.String objectStructureName) throws java.rmi.RemoteException
getObjectStructureInfo
in interface MicServiceRemote
java.rmi.RemoteException