com.ibm.tivoli.maximo.iotservices

Class IoTConnectionService

java.lang.Object

psdi.server.AppService

com.ibm.tivoli.maximo.iotservices.IoTConnectionService

All Implemented Interfaces:

IoTConnectionServiceRemote, IoTServicesConstants, java.rmi.Remote, MboServerInterface, MaxRemoteProxy, AppServiceRemote, Dependable, Service, ServiceRemote, FixedLoggerNames, FixedLoggers

public class IoTConnectionService
extends AppService
implements IoTConnectionServiceRemote, IoTServicesConstants

Field Summary

Fields inherited from interface com.ibm.tivoli.maximo.iotservices.IoTServicesConstants

ACTIVE, AGGMSGSCHEMA, AGGTIMERANGE, BODY, DESCRIPTION, DEVICEIDTAG, DEVICETYPE, DEVICETYPEDESC, DEVICETYPEDESCRTAG, DEVICETYPETAG, ENDPOINTNAME, ENDPOINTVALUE, EXTSYSTEM, FEEDMAPPINGPROP, GROUPLEVEL, HASIOTCFG, HISTMAPPER, HISTQUERY, HTTPMETHOD, IFACENAME, INSTANCENAME, IOTCFG, IOTCONNSERVLOGGER, IOTSERVEP, IOTSERVICENAME, ISDEFAULT, LABEL, LASTMESSAGETAG, MAPPER, METERNAME, METHOD, NAMETAG, PAYLOADIDATTR, PINGENDPOINT, PROCESSOR, PROPAGGREGATION, PROPERTY, READINGDATEFORMAT, READINGDATETAGMAP, READINGDATETAGNAME, RESULTTAGNAME, RULENAME, SEQUENCE, SORT, USEDBY, USEDWITH, USEDWITH_getAggregateResultForDeviceType, USEDWITH_getAllDevicetypes, USEDWITH_getDevices, USEDWITH_getLastMessage, USEDWITH_getMessage, USEDWITH_getSampleAggregate, USEWITH, VALUE, VALUETAG

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
IoTConnectionService()
IoTConnectionService(MXServer mxServer)

Method Summary

Modifier and Type	Method and Description
boolean	anyDeviceTypesMapped(MboRemote iotserv)
void	canDeleteDeviceType(MboRemote iotdevtype)
java.util.Map<java.lang.String,java.lang.Object>	checkCronTaskInstance(java.lang.String instancename)
void	clearDeviceReferenceAssetLocationLevel(MboRemote iotconfig)
void	clearDeviceRefernce(MboRemote iotf) Clear reference for device type and device id from asset and location meter for one device type.
void	clearDeviceRefernceForService(MboRemote iotservice) Clear reference for device type and device id from asset and location meter.
void	createAsset(java.lang.String iotfOrg, java.lang.String deviceType, com.ibm.json.java.JSONObject deviceJO)
void	deleteDocument(java.util.Map<java.lang.String,java.lang.Object> metaData, java.lang.String postUrl, HTTPHandler handler)
java.util.List<java.lang.Object>	devices(java.lang.String deviceType)
java.util.List<java.lang.Object>	getAllDeviceTypes(MboRemote iotserv, java.lang.String sort)
java.lang.String	getAnyHistorianDatabaseName(java.lang.String orgid, java.lang.String historian, java.lang.String choice, java.lang.String bucket, java.util.Date dt, int offset, boolean isDefault)
java.util.List<java.lang.Object>	getDevices(MboRemote iotserv, java.lang.String deviceType, java.lang.String limit)
java.util.List<java.lang.Object>	getDeviceTypeList(MboRemote iotserv, java.lang.String sort, boolean isMapped)
java.util.List<java.lang.String>	getEndPointValues(java.lang.String servicename)
java.lang.String	getHistorianDatabaseName(java.lang.String orgid, java.lang.String historian, java.util.Date dt)
java.util.Map<java.lang.String,java.lang.Object>	getLastMessageFromCache(MboRemote iotService, java.lang.String deviceType)
java.util.Map<java.lang.String,java.lang.Object>	getLastMessageFromCacheForDevice(MboRemote iotserv, java.lang.String deviceType, java.lang.String deviceid)
java.util.List<java.lang.Object>	getNotMappedYetDeviceTypes(MboRemote iotserv, java.lang.String sort) Deprecated.
com.ibm.json.java.JSONObject	getSampleAggregateResultForDeviceType(MboRemote iotService, java.lang.String deviceType, java.lang.String feedMapProperty, java.lang.String deviceid) Get the aggregated data, using the getSampleAggregateResultForDeviceType endpoint.
java.util.List<java.lang.String>	getTimePeriods(MboRemote iotserv)
void	init() Initialize the Application Service.
boolean	isDeviceTypeAssociated(MboRemote iotservice, java.lang.String deviceType)
static java.lang.String	listOwnerChain(MboSet mboset)
com.ibm.json.java.JSONObject	pingIoT(MboRemote iotserv, boolean iotcfg)
void	refreshIoTServicesCache(MboSet mboset) Refresh Service Cache.

Methods inherited from class psdi.server.AppService

checkSecurity, configure, 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

Methods inherited from class java.lang.Object

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

Methods inherited from interface psdi.server.AppServiceRemote

checkSecurity, getCriteria, getCurrentState, getLiveObjCount, getMboSet, getName, getSchemaOwner, getSetForRelationship, getSetFromKeys, getStateCmdList, getStateList, getURL, verifyUser, verifyUser

Methods inherited from interface psdi.server.ServiceRemote

isAppService, isSingletonService, restart

Constructor Detail

IoTConnectionService

public IoTConnectionService(MXServer mxServer)
                     throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

IoTConnectionService

public IoTConnectionService()
                     throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException

Method Detail

init

public void init()

Description copied from class: AppService

Initialize the Application Service.

Specified by:

init in interface Service

Overrides:

init in class AppService

See Also:

Service

pingIoT

public com.ibm.json.java.JSONObject pingIoT(MboRemote iotserv,
                                            boolean iotcfg)
                                     throws MXException,
                                            java.rmi.RemoteException

Throws:

MXException

java.rmi.RemoteException

getAllDeviceTypes

public java.util.List<java.lang.Object> getAllDeviceTypes(MboRemote iotserv,
                                                          java.lang.String sort)
                                                   throws java.rmi.RemoteException,
                                                          MXException

Throws:

java.rmi.RemoteException

MXException

getDeviceTypeList

public java.util.List<java.lang.Object> getDeviceTypeList(MboRemote iotserv,
                                                          java.lang.String sort,
                                                          boolean isMapped)
                                                   throws java.rmi.RemoteException,
                                                          MXException

Throws:

java.rmi.RemoteException

MXException

getNotMappedYetDeviceTypes

@Deprecated
public java.util.List<java.lang.Object> getNotMappedYetDeviceTypes(MboRemote iotserv,
                                                                                java.lang.String sort)
                                                                         throws java.rmi.RemoteException,
                                                                                MXException

Deprecated.

Throws:

java.rmi.RemoteException

MXException

getLastMessageFromCache

public java.util.Map<java.lang.String,java.lang.Object> getLastMessageFromCache(MboRemote iotService,
                                                                                java.lang.String deviceType)
                                                                         throws java.rmi.RemoteException,
                                                                                MXException

Throws:

java.rmi.RemoteException

MXException

getLastMessageFromCacheForDevice

public java.util.Map<java.lang.String,java.lang.Object> getLastMessageFromCacheForDevice(MboRemote iotserv,
                                                                                         java.lang.String deviceType,
                                                                                         java.lang.String deviceid)
                                                                                  throws java.rmi.RemoteException,
                                                                                         MXException

Throws:

java.rmi.RemoteException

MXException

getSampleAggregateResultForDeviceType

public com.ibm.json.java.JSONObject getSampleAggregateResultForDeviceType(MboRemote iotService,
                                                                          java.lang.String deviceType,
                                                                          java.lang.String feedMapProperty,
                                                                          java.lang.String deviceid)
                                                                   throws java.rmi.RemoteException,
                                                                          MXException

Get the aggregated data, using the getSampleAggregateResultForDeviceType endpoint. We want only one record worth, even if multiple are reported.

Parameters:

iotService - IoTService Mbo

deviceType -

feedMapProperty -

Returns:

the JSONObject or null

Throws:

java.rmi.RemoteException

MXException

clearDeviceRefernceForService

public void clearDeviceRefernceForService(MboRemote iotservice)
                                   throws java.rmi.RemoteException,
                                          MXException

Clear reference for device type and device id from asset and location meter.

Parameters:

iotf - IoTF organization object

Throws:

MXException

java.rmi.RemoteException

clearDeviceReferenceAssetLocationLevel

public void clearDeviceReferenceAssetLocationLevel(MboRemote iotconfig)
                                            throws java.rmi.RemoteException,
                                                   MXException

Throws:

java.rmi.RemoteException

MXException

clearDeviceRefernce

public void clearDeviceRefernce(MboRemote iotf)
                         throws java.rmi.RemoteException,
                                MXException

Clear reference for device type and device id from asset and location meter for one device type.

Parameters:

iotf - IoTF device type object

Throws:

MXException

java.rmi.RemoteException

getEndPointValues

public java.util.List<java.lang.String> getEndPointValues(java.lang.String servicename)
                                                   throws java.rmi.RemoteException,
                                                          MXException

Throws:

java.rmi.RemoteException

MXException

refreshIoTServicesCache

public void refreshIoTServicesCache(MboSet mboset)
                             throws MXException,
                                    java.rmi.RemoteException

Refresh Service Cache. Called by IoT MboSets on commit.

Specified by:

refreshIoTServicesCache in interface IoTConnectionServiceRemote

Throws:

MXException

java.rmi.RemoteException

getDevices

public java.util.List<java.lang.Object> getDevices(MboRemote iotserv,
                                                   java.lang.String deviceType,
                                                   java.lang.String limit)
                                            throws java.rmi.RemoteException,
                                                   MXException

Throws:

java.rmi.RemoteException

MXException

checkCronTaskInstance

public java.util.Map<java.lang.String,java.lang.Object> checkCronTaskInstance(java.lang.String instancename)
                                                                       throws java.rmi.RemoteException,
                                                                              MXException

Throws:

java.rmi.RemoteException

MXException

devices

public java.util.List<java.lang.Object> devices(java.lang.String deviceType)
                                         throws MXException,
                                                java.io.IOException

Throws:

MXException

java.io.IOException

createAsset

public void createAsset(java.lang.String iotfOrg,
                        java.lang.String deviceType,
                        com.ibm.json.java.JSONObject deviceJO)
                 throws MXException

Throws:

MXException

getHistorianDatabaseName

public java.lang.String getHistorianDatabaseName(java.lang.String orgid,
                                                 java.lang.String historian,
                                                 java.util.Date dt)
                                          throws java.rmi.RemoteException,
                                                 MXException

Throws:

java.rmi.RemoteException

MXException

getAnyHistorianDatabaseName

public java.lang.String getAnyHistorianDatabaseName(java.lang.String orgid,
                                                    java.lang.String historian,
                                                    java.lang.String choice,
                                                    java.lang.String bucket,
                                                    java.util.Date dt,
                                                    int offset,
                                                    boolean isDefault)
                                             throws java.rmi.RemoteException,
                                                    MXException

Throws:

java.rmi.RemoteException

MXException

deleteDocument

public void deleteDocument(java.util.Map<java.lang.String,java.lang.Object> metaData,
                           java.lang.String postUrl,
                           HTTPHandler handler)
                    throws MXException,
                           java.rmi.RemoteException

Throws:

MXException

java.rmi.RemoteException

canDeleteDeviceType

public void canDeleteDeviceType(MboRemote iotdevtype)
                         throws java.rmi.RemoteException,
                                MXException

Throws:

java.rmi.RemoteException

MXException

anyDeviceTypesMapped

public boolean anyDeviceTypesMapped(MboRemote iotserv)
                             throws MXException,
                                    java.rmi.RemoteException

Throws:

MXException

java.rmi.RemoteException

isDeviceTypeAssociated

public boolean isDeviceTypeAssociated(MboRemote iotservice,
                                      java.lang.String deviceType)
                               throws java.rmi.RemoteException,
                                      MXException

Throws:

java.rmi.RemoteException

MXException

getTimePeriods

public java.util.List<java.lang.String> getTimePeriods(MboRemote iotserv)
                                                throws java.rmi.RemoteException,
                                                       MXException

Throws:

java.rmi.RemoteException

MXException

listOwnerChain

public static java.lang.String listOwnerChain(MboSet mboset)
                                       throws java.rmi.RemoteException

Throws:

java.rmi.RemoteException