com.ibm.tivoli.maximo.iotservices.mapper

Class IotProcessor

java.lang.Object

com.ibm.tivoli.maximo.fdmbo.DefaultResourceProcessor

com.ibm.tivoli.maximo.iotservices.historian.HistorianProcessor

com.ibm.tivoli.maximo.iotservices.mapper.IotProcessor

All Implemented Interfaces:

IoTHistorianProcessor, FixedLoggerNames, FixedLoggers

Direct Known Subclasses:

IoTCloudantProcessor, IotGenericProcessor

public abstract class IotProcessor
extends HistorianProcessor
implements IoTHistorianProcessor, FixedLoggers

Field Summary

Fields

Modifier and Type	Field and Description
static long	NOACCESSCHECK
static long	NOVALIDATION_AND_NOACTION

Fields inherited from class com.ibm.tivoli.maximo.fdmbo.DefaultResourceProcessor

formattedUrl

Fields inherited from interface psdi.util.logging.FixedLoggers

APPLOGGER, CRONTASKLOGGER, CRONTASKMGRLOGGER, CRONTASKMGRSQLLOGGER, DBCONNECTIONLOGGER, DDLOGGER, DMLOGGER, EVENTLOGGER, EXCEPTIONLOGGER, MAILLOGGER, MAXIMOLOGGER, MTLOGGER, NULLMBOPOINTER, SECURITY, SENDFAILEDLOGGER, SERVICELOGGER, SQLLOGGER

Fields inherited from interface psdi.util.logging.FixedLoggerNames

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 Summary

Constructors

Constructor and Description
IotProcessor()

Method Summary

Modifier and Type	Method and Description
protected java.util.List	getDeviceidsForDeviceTypeAsset(java.lang.String deviceType, IoTMeterToPayloadMappingInfo mappingInfo)
protected java.util.List	getDeviceidsForDeviceTypeLocation(java.lang.String deviceType, IoTMeterToPayloadMappingInfo mappingInfo)
protected abstract java.util.List	getIOTPlatformRestURL(java.lang.String iotServiceName, java.lang.String endPointName, java.lang.String histURL, java.lang.String deviceType, IoTMeterToPayloadMappingInfo mappingInfo, java.util.Date lastRun, IoTConnectionService iotfProc, java.lang.String useWith)
abstract java.util.Map	getReadingDate(com.ibm.json.java.JSONObject jo, java.lang.String iotServiceName, IoTMeterToPayloadMappingInfo mappingInfo)
protected abstract java.lang.String	getResultTagName(java.lang.String iotServiceName, IoTMeterToPayloadMappingInfo mappingInfo)
protected void	mapAssetMeterFeedData(java.lang.String deviceid, java.lang.String deviceType, java.util.Date readingDate, IoTMeterToPayloadMappingInfo mappingInfo, com.ibm.json.java.JSONObject jo, java.lang.String sensorValue)
protected void	mapLocationMeterFeedData(java.lang.String deviceid, java.lang.String deviceType, java.util.Date readingDate, IoTMeterToPayloadMappingInfo mappingInfo, com.ibm.json.java.JSONObject jo, java.lang.String sensorValue)
void	processHistorianData(IoTMeterToPayloadMappingInfo mappingInfo, java.lang.String histURL, URLFormatter uf, java.lang.String endPointName, java.lang.String iotServiceName, java.lang.String histDBName, java.lang.String deviceType, java.util.Date lastRun, java.lang.String useWith, boolean useJMSQueue)
abstract java.lang.String	setReadingsForHistorianData(com.ibm.json.java.JSONObject jo, IoTMeterToPayloadMappingInfo mappingInfo, java.util.Date readingDate)
void	syncMeterReadings(java.lang.String iotServiceName, java.lang.String deviceType, java.lang.String instanceName, java.util.Date lastRun, boolean useJMSQueue)

Methods inherited from class com.ibm.tivoli.maximo.iotservices.historian.HistorianProcessor

pingHistorian, processResource

Methods inherited from class com.ibm.tivoli.maximo.fdmbo.DefaultResourceProcessor

getPagingParams, processPaging

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

NOACCESSCHECK

public static final long NOACCESSCHECK

See Also:

Constant Field Values

NOVALIDATION_AND_NOACTION

public static final long NOVALIDATION_AND_NOACTION

See Also:

Constant Field Values

Constructor Detail

IotProcessor

public IotProcessor()
             throws MXException,
                    java.rmi.RemoteException

Throws:

MXException

java.rmi.RemoteException

Method Detail

syncMeterReadings

public void syncMeterReadings(java.lang.String iotServiceName,
                              java.lang.String deviceType,
                              java.lang.String instanceName,
                              java.util.Date lastRun,
                              boolean useJMSQueue)
                       throws MXException,
                              java.rmi.RemoteException

Specified by:

syncMeterReadings in interface IoTHistorianProcessor

Throws:

MXException

java.rmi.RemoteException

processHistorianData

public void processHistorianData(IoTMeterToPayloadMappingInfo mappingInfo,
                                 java.lang.String histURL,
                                 URLFormatter uf,
                                 java.lang.String endPointName,
                                 java.lang.String iotServiceName,
                                 java.lang.String histDBName,
                                 java.lang.String deviceType,
                                 java.util.Date lastRun,
                                 java.lang.String useWith,
                                 boolean useJMSQueue)
                          throws MXException,
                                 java.rmi.RemoteException

Throws:

MXException

java.rmi.RemoteException

mapAssetMeterFeedData

protected void mapAssetMeterFeedData(java.lang.String deviceid,
                                     java.lang.String deviceType,
                                     java.util.Date readingDate,
                                     IoTMeterToPayloadMappingInfo mappingInfo,
                                     com.ibm.json.java.JSONObject jo,
                                     java.lang.String sensorValue)
                              throws java.rmi.RemoteException,
                                     MXException

Throws:

java.rmi.RemoteException

MXException

mapLocationMeterFeedData

protected void mapLocationMeterFeedData(java.lang.String deviceid,
                                        java.lang.String deviceType,
                                        java.util.Date readingDate,
                                        IoTMeterToPayloadMappingInfo mappingInfo,
                                        com.ibm.json.java.JSONObject jo,
                                        java.lang.String sensorValue)
                                 throws java.rmi.RemoteException,
                                        MXException

Throws:

java.rmi.RemoteException

MXException

getDeviceidsForDeviceTypeAsset

protected java.util.List getDeviceidsForDeviceTypeAsset(java.lang.String deviceType,
                                                        IoTMeterToPayloadMappingInfo mappingInfo)
                                                 throws java.rmi.RemoteException,
                                                        MXException

Throws:

java.rmi.RemoteException

MXException

getDeviceidsForDeviceTypeLocation

protected java.util.List getDeviceidsForDeviceTypeLocation(java.lang.String deviceType,
                                                           IoTMeterToPayloadMappingInfo mappingInfo)
                                                    throws java.rmi.RemoteException,
                                                           MXException

Throws:

java.rmi.RemoteException

MXException

getIOTPlatformRestURL

protected abstract java.util.List getIOTPlatformRestURL(java.lang.String iotServiceName,
                                                        java.lang.String endPointName,
                                                        java.lang.String histURL,
                                                        java.lang.String deviceType,
                                                        IoTMeterToPayloadMappingInfo mappingInfo,
                                                        java.util.Date lastRun,
                                                        IoTConnectionService iotfProc,
                                                        java.lang.String useWith)
                                                 throws MXException,
                                                        java.rmi.RemoteException

Throws:

MXException

java.rmi.RemoteException

setReadingsForHistorianData

public abstract java.lang.String setReadingsForHistorianData(com.ibm.json.java.JSONObject jo,
                                                             IoTMeterToPayloadMappingInfo mappingInfo,
                                                             java.util.Date readingDate)
                                                      throws MXException

Throws:

MXException

getReadingDate

public abstract java.util.Map getReadingDate(com.ibm.json.java.JSONObject jo,
                                             java.lang.String iotServiceName,
                                             IoTMeterToPayloadMappingInfo mappingInfo)
                                      throws MXException,
                                             java.rmi.RemoteException

Throws:

MXException

java.rmi.RemoteException

getResultTagName

protected abstract java.lang.String getResultTagName(java.lang.String iotServiceName,
                                                     IoTMeterToPayloadMappingInfo mappingInfo)