public class NokiaOMS1350RestCollector extends Collector
collectorDescription, collectorName, collectorPort, dataStore, propsFileName, running| Constructor and Description |
|---|
NokiaOMS1350RestCollector(java.lang.String collectorName,
java.lang.String collectorDescription)
Constructor
|
| Modifier and Type | Method and Description |
|---|---|
void |
AddTopologicalConnection(TopologicalLink topologicalLink,
java.lang.String neId)
Load AddTopologicalConnection class attributes into hashmap to be used for
creating entity
|
protected void |
collectData(int dataSourceId,
java.lang.String address,
java.lang.String mask)
This method is responsible for ensuring that data is updated as appropriate, that is, the Collector should check
the EMS for new data and update any internal stores as appropriate.
|
protected void |
doFullDiscovery(java.lang.String nodeId)
Performs a Full Discovery operation
|
protected NetworkEquipment |
getAllEquipment()
Performs a getAllEquipment operation
|
protected java.util.List<Elements> |
getAllNetworkElements()
Performs a getAllNetworkElements operation
|
protected java.util.ArrayList<PhysicalPorts> |
getAllPhysicalPorts()
Performs a getAllPhysicalPorts operation
|
protected java.util.ArrayList<TopologicalLinks> |
getAllTopologicalLinks()
Performs a getAllNetworkElements operation
|
static java.lang.String |
getBasicAuthorization(java.lang.String username,
java.lang.String password) |
protected java.util.ArrayList<TopologicalLink> |
getTopologicalLink()
Performs a getTopologicalLink operation
|
boolean |
HTTPClientInitialzation() |
protected void |
initDataStore()
Initializes data source as specified in the properties file
|
protected boolean |
initialise()
Initialize collector with data gather from properties file
|
protected boolean |
isGetEntities() |
protected boolean |
isGetLayer1Connections() |
protected boolean |
isGetLayer2Connections() |
protected boolean |
isGetLayer3Connections() |
void |
loadAndAddTopologicalConnections(java.util.ArrayList<TopologicalLinks> alTopologicalLinks,
java.lang.String NEName,
java.lang.String neId)
Load loadAndAddTopologicalConnections class attributes into hashmap to be
used for creating entity
|
void |
loadEquipmentNodeCard(EquipmentNode equipNode,
NetworkDevice neElement)
Load EquipmentNode class attributes into hashmap to be used for creating
entity
|
void |
loadEquipmentNodeShelf(EquipmentNode equipNode,
NetworkDevice neElement)
Load EquipmentNode class attributes into hashmap to be used for creating
entity
|
void |
loadEquipmentNodeSlot(EquipmentNode equipNode,
NetworkDevice neElement)
Load EquipmentNode class attributes into hashmap to be used for creating
entity
|
void |
loadEquipmentPort(PhysicalPort physicalPort,
NetworkDevice neElement)
Load Equipment Port class attributes into hashmap to be used for creating
entity
|
static void |
main(java.lang.String[] args)
Runs the Nokia OMS 1350 collector
|
boolean |
oms1350Authenticate()
Authenticate to Nokia OMS 130 while performing a Full Discovery operation
3 - Level Authentication to Nokia OMS 1350
|
java.util.List<NetworkDevice> |
parseNetworkDeviceData(java.util.List<Elements> nodeList) |
protected void |
processPhysicalInventoryData(java.util.List<Elements> processNodeList,
NetworkEquipment netwEquipment,
java.util.ArrayList<TopologicalLinks> alTopoConnections,
java.util.ArrayList<TopologicalLink> allTopologyConnections)
Process data for Physical Inventory add the Entities/Interfaces to the
Datastore
|
void |
processTopologicalLink(java.util.List<TopologicalLink> allTopoLinks,
java.lang.String NEName,
java.lang.String neId) |
java.util.ArrayList<TopologicalLink> |
readallTopologicalDataFromServer()
Reads GetAllTopological data from server
|
java.lang.String |
readJsonData(java.lang.String fileName)
Reads readJsonData data from server
|
java.util.List<Elements> |
readNetworkElementsDataFromServer()
Reads NetworkElements data from server
|
NetworkEquipment |
readNetworkEquipDataFromServer()
Reads NetworkEquipment data from server
|
java.util.ArrayList<PhysicalPorts> |
readPhysicalPortsDataFromServer()
Reads NetworkElements data from server
|
java.util.ArrayList<TopologicalLinks> |
readTopologicalDataFromServer()
Reads Topological data from server
|
protected boolean |
setConnectionParameters(WebSocketTransport webSocketTransport,
java.lang.String remoteUsername,
java.lang.String remotePassword,
java.lang.String remoteHost,
java.lang.String remoteServiceName,
java.lang.String remotePreHostname,
java.lang.String remotePreUserName,
java.lang.String remotePrePassword,
java.lang.Integer remotePort,
java.lang.String remotekeyStoreFileName,
java.lang.String remotekeyStorePassword,
java.lang.String remoteHTTPversion,
java.lang.String remoteResponseTimeout,
java.lang.Integer remoteRefreshInterval,
java.lang.Boolean remoteEnableSSL,
java.lang.String pathToKeyStoreFile,
java.lang.String setProtocolValue,
boolean enableManualST,
java.lang.String serviceTicket,
int maxBufferSize,
boolean isSingleAuthentication)
Setting up websocket connection parameters for REST
|
protected boolean |
setConnectionParametersHTTP(WebSocketTransport webSocketTransport,
java.lang.String remoteHost,
java.lang.String remoteHTTPversion,
java.lang.String remoteResponseTimeout)
Setting up websocket connection parameters for REST
|
protected void |
setGetEntities(java.lang.String getEntitiesFlag) |
protected void |
setGetLayer1Connections(java.lang.String getLayer1Connections) |
protected void |
setGetLayer2Connections(java.lang.String getLayer2Connections) |
protected void |
setGetLayer3Connections(java.lang.String getLayer3Connections) |
static void |
setPropsFile(java.util.Properties propsFile) |
java.lang.String |
UpdateData(int dataSourceId,
int requestType,
java.lang.String address,
java.lang.String mask)
UpdateData invokes the collectData method which is responsible for ensuring
that data is updated as appropriate, that is, the Collector should check the
EMS for new data and update any internal stores as appropriate.
|
GetAfData, GetAmfData, GetAssociatedAddresses, GetAssociatedAddresses, GetAusfData, getCommandLineArgument, GetConnections, GetConnections, GetDeviceInfo, GetDeviceInfo, GetDeviceInfo, GetDeviceList, GetEirData, GetENodeBData, GetEntities, GetEntities, GetGNodeBData, GetHssData, GetInfo, GetInventory, GetInventory, GetLayer1Connections, GetLayer1Connections, GetLayer2Connections, GetLayer2Connections, GetLayer2Vpns, GetLayer2Vpns, GetLayer3Connections, GetLayer3Connections, GetLayer3Vpns, GetLayer3Vpns, GetMmeData, GetMplsInterfaces, GetMplsInterfaces, GetNefData, GetNrfData, GetNssfData, GetPcfData, GetPcrfData, GetPgwData, getPortNumberArgument, getPropertiesFileNameArgument, getPropertyValue, GetRanData, GetSAEGatewayData, GetSgwData, GetSmfData, GetUdmData, GetUpfData, initialiseDataStore, isRunning, loadPropertiesFile, setDataStore, setRunning, shutdown, startup, startuppublic NokiaOMS1350RestCollector(java.lang.String collectorName,
java.lang.String collectorDescription)
collectorName - The name of the collectorcollectorDescription - A description of the collectorpublic static void main(java.lang.String[] args)
args - Command line arguments, e.g. -propsFile <props file name>public boolean oms1350Authenticate()
None - public boolean HTTPClientInitialzation()
protected boolean initialise()
protected void initDataStore()
protected boolean setConnectionParametersHTTP(WebSocketTransport webSocketTransport, java.lang.String remoteHost, java.lang.String remoteHTTPversion, java.lang.String remoteResponseTimeout)
webSocketTransport - webSocketTransport classremoteUsername - Nokia OMS 1350 usernameremotePassword - Nokia OMS 1350 passwordremoteHost - Nokia OMS 1350 ip addressremoteServiceName - Nokia OMS 1350 Service NameremotePreUsername - Nokia OMS 1350 Presentation Server usernameremotePrePassword - Nokia OMS 1350 Presentation Server passwordremotePreHost - Nokia OMS 1350 Presentation Server ip addressremotePort - Nokia OMS 1350 portremotekeyStoreFileName - Nokia OMS 1350 usernameremotekeyStorePassword - keyStorePasswordremoteHTTPversion - HTTP versionremoteResponseTimeout - Response Timeout in secondssetRefreshInterval - Refresh Interval in secondsprotected boolean setConnectionParameters(WebSocketTransport webSocketTransport, java.lang.String remoteUsername, java.lang.String remotePassword, java.lang.String remoteHost, java.lang.String remoteServiceName, java.lang.String remotePreHostname, java.lang.String remotePreUserName, java.lang.String remotePrePassword, java.lang.Integer remotePort, java.lang.String remotekeyStoreFileName, java.lang.String remotekeyStorePassword, java.lang.String remoteHTTPversion, java.lang.String remoteResponseTimeout, java.lang.Integer remoteRefreshInterval, java.lang.Boolean remoteEnableSSL, java.lang.String pathToKeyStoreFile, java.lang.String setProtocolValue, boolean enableManualST, java.lang.String serviceTicket, int maxBufferSize, boolean isSingleAuthentication)
webSocketTransport - webSocketTransport classremoteUsername - Nokia OMS 1350 usernameremotePassword - Nokia OMS 1350 passwordremoteHost - Nokia OMS 1350 ip addressremoteServiceName - Nokia OMS 1350 Service NameremotePreUsername - Nokia OMS 1350 Presentation Server usernameremotePrePassword - Nokia OMS 1350 Presentation Server passwordremotePreHost - Nokia OMS 1350 Presentation Server ip addressremotePort - Nokia OMS 1350 portremotekeyStoreFileName - Nokia OMS 1350 usernameremotekeyStorePassword - keyStorePasswordremoteHTTPversion - HTTP versionremoteResponseTimeout - Response Timeout in secondssetRefreshInterval - Refresh Interval in secondspublic static java.lang.String getBasicAuthorization(java.lang.String username,
java.lang.String password)
username - password - protected void doFullDiscovery(java.lang.String nodeId)
throws java.io.IOException
nodeId - Node Id for Partial Discovery operation. When a non-zero value is
supplied, Partial Discovery is performed, else Full Discovery is
performed insteadjava.io.IOException - ,TolAttributeException,TolCommunicationExceptionpublic java.lang.String readJsonData(java.lang.String fileName)
fileName - public NetworkEquipment readNetworkEquipDataFromServer()
public java.util.List<Elements> readNetworkElementsDataFromServer() throws JsonParseException, java.io.IOException
java.io.IOExceptionJsonParseExceptionpublic java.util.ArrayList<PhysicalPorts> readPhysicalPortsDataFromServer()
public java.util.ArrayList<TopologicalLinks> readTopologicalDataFromServer()
public java.util.ArrayList<TopologicalLink> readallTopologicalDataFromServer()
protected NetworkEquipment getAllEquipment() throws java.io.IOException
None - It will get all the list of Equipments from OMS. First it will
return the location of JSON file and next send the request to
download the JSON filejava.io.IOException - ,TolAttributeException,TolCommunicationExceptionprotected java.util.List<Elements> getAllNetworkElements() throws java.io.IOException
None - It will get all the list of Elements from OMS. First it will
return the location of JSON file and next send the request to
download the JSON filejava.io.IOException - ,TolAttributeException,TolCommunicationExceptionprotected java.util.ArrayList<PhysicalPorts> getAllPhysicalPorts() throws java.io.IOException
None - It will get all the list of Elements from OMS. First it will
return the location of JSON file and next send the request to
download the JSON filejava.io.IOException - ,TolAttributeException,TolCommunicationExceptionprotected java.util.ArrayList<TopologicalLinks> getAllTopologicalLinks() throws java.io.IOException
None - It will get all the list of Topological Links from OMS. First it
will return the location of JSON file and next send the request to
download the JSON filejava.io.IOException - ,TolAttributeException,TolCommunicationExceptionprotected java.util.ArrayList<TopologicalLink> getTopologicalLink() throws java.io.IOException
None - It will get all the list of Topological Links from OMS. First it
will return the location of JSON file and next send the request to
download the JSON filejava.io.IOException - ,TolAttributeException,TolCommunicationExceptionprotected void collectData(int dataSourceId,
java.lang.String address,
java.lang.String mask)
CollectorThis method is responsible for ensuring that data is updated as appropriate, that is, the Collector should check the EMS for new data and update any internal stores as appropriate.
collectData in class CollectordataSourceId - Holds the ID of the data source which should be updatedaddress - If mask is not defined then it holds the address (IP or native id) of the device to refresh, or else it holds the subnet to
refresh.mask - Holds the subnet mask, or is not definedpublic java.lang.String UpdateData(int dataSourceId,
int requestType,
java.lang.String address,
java.lang.String mask)
UpdateData invokes the collectData method which is responsible for ensuring that data is updated as appropriate, that is, the Collector should check the EMS for new data and update any internal stores as appropriate.
If the Collector does not need to update its data then it does not need to perform any work other than returning the response message "<updateResponse></updateResponse>".
Note: Is it the Collector's responsibility to determine which devices the supplied IP relates to; the IP is NOT guaranteed to be the device id.
UpdateData in class CollectordataSourceId - Holds the ID of the data source which should be updatedrequestType - The type of requestaddress - If mask is not defined then it holds the IP of the device to
refresh, or else it holds the subnet to refreshmask - Holds the subnet mask, or is not defined<updateResponse></updateResponse>protected void processPhysicalInventoryData(java.util.List<Elements> processNodeList, NetworkEquipment netwEquipment, java.util.ArrayList<TopologicalLinks> alTopoConnections, java.util.ArrayList<TopologicalLink> allTopologyConnections) throws java.io.IOException
processNodeList - List of nodesNetworkEquipment - NetworkEquipment List of Network Equipmentjava.io.IOExceptionpublic void loadAndAddTopologicalConnections(java.util.ArrayList<TopologicalLinks> alTopologicalLinks, java.lang.String NEName, java.lang.String neId)
ArrayList - List of items belong to TopologicalLinkspublic void processTopologicalLink(java.util.List<TopologicalLink> allTopoLinks, java.lang.String NEName, java.lang.String neId)
public void AddTopologicalConnection(TopologicalLink topologicalLink, java.lang.String neId)
TopologicalLinks - item belong to TopologicalLinkpublic void loadEquipmentNodeSlot(EquipmentNode equipNode, NetworkDevice neElement)
EquipmentNode - List of items belong to EquipmentNodeneName - The ID of Network Elementpublic void loadEquipmentNodeCard(EquipmentNode equipNode, NetworkDevice neElement)
EquipmentNode - List of items belong to EquipmentNodeneName - The ID of Network Elementpublic void loadEquipmentNodeShelf(EquipmentNode equipNode, NetworkDevice neElement)
EquipmentNode - List of items belong to EquipmentNodeneName - The ID of Network Elementpublic void loadEquipmentPort(PhysicalPort physicalPort, NetworkDevice neElement)
PhysicalPort - List of items belong to Physical PortElements - The Network Element datapublic java.util.List<NetworkDevice> parseNetworkDeviceData(java.util.List<Elements> nodeList)
nodeList - protected boolean isGetEntities()
protected void setGetEntities(java.lang.String getEntitiesFlag)
getEntities - the getEntities to setprotected boolean isGetLayer1Connections()
protected void setGetLayer1Connections(java.lang.String getLayer1Connections)
getLayer1Connections - the getLayer1Connections to setprotected boolean isGetLayer2Connections()
protected void setGetLayer2Connections(java.lang.String getLayer2Connections)
getLayer2Connections - the getLayer2Connections to setprotected boolean isGetLayer3Connections()
protected void setGetLayer3Connections(java.lang.String getLayer3Connections)
getLayer3Connections - the getLayer3Connections to setpublic static void setPropsFile(java.util.Properties propsFile)