高效构建 CIM 事件模型

// Define the name of CIM class to be created

String   filterClassName = "CIM_IndicationFilter";

// Define the filter string for CIM_IndicationFilter instance

String   filterString = "SELECT * FROM CIM_InstCreation WHERE SourceInstance
 ISA CIM_StorageVolume";

// Get the CIM class definition from the CIMOM

CIMClass filterClass = _client.getClass(new CIMObjectPath(filterClassName));

// Create an instance of the CIM_IndicationFilter class

CIMInstance filterInstance = filterClass.newInstance();

// Set the name of the filter

filterInstance.setProperty("Name",
                            new CIMValue("PCL_Event",
                            new CIMDataType(CIMDataType.STRING)));

// Set the filter string to select CIM events

filterInstance.setProperty("Query",
                            new CIMValue(filterString,
                            new CIMDataType(CIMDataType.STRING)));

// Set the query language (WQL) to parse the query string

filterInstance.setProperty("QueryLanguage",
                            new CIMValue("WQL",
                            new CIMDataType(CIMDataType.STRING)));

// Set the source name space of the filter

filterInstance.setProperty("SourceNamespace",
                            new CIMValue(_namespace,
                            new CIMDataType(CIMDataType.STRING)));

// Create an instance of CIM_IndicationFilter on the target CIM server

CIMObjectPath filterCOP = _client.createInstance(new CIMObjectPath(),
                                                 filterInstance);

// Create a CIMIndicationListenertList instance

CIMIndicationListenertList _indicationClient = 
new CIMIndicationListenertList();
        
/* 
* Add a inner listener to the list, because if there is only one listener in
* CIMIndicationListenertList, it will get all event no matter the event is the
* certain listener registered to listen or not, we need to add a InnerListener
* which implements CIMListener and doing nothing
*/

_indicationClient.addListener(new InnerListener());

/*
* Add IndicationListenerList to a dispatcher, CIMEvent will be dispatched to
* target listener according to the hash code of one listener
*/

CIMEventDispatcher dispatcher = new CIMEventDispatcher(_indicationClient);

// Create an new CIMIndicationHandler instance which wraps the dispatcher

CIMIndicationHandler indicationHdlr = new CIMIndicationHandler(dispatcher);

// Create a HttpServerConnection with the specified port
// NOTE: This target port is shared by all the event handlers

HttpServerConnection _serverConn = new HttpServerConnection(
                     new HttpConnectionHandler(indicationHdlr), targetPort);
_serverConn.setName("CIMListener - Http Server");
_serverConn.start();

// You can also add listener after HttpServerConnection has started

// Create internal listener, InternalListener should implement CIMListener and
// have its own function

InternalListener internalListener = new InternalListener();

// Add internal listener to CIMIndicationListenertList instance

_indicationClient.addListener(internalListener);

// Create a listener destination instance

CIMClass    indicationDestinationClass = _client.getClass(
                  new CIMObjectPath("CIM_ListenerDestinationCIMXML"), false);
CIMInstance cimListener = indicationDestinationClass.newInstance();

// Set the properties of CIM instance, and which properties are mandatory are
// highly depending on the implementation of CIM providers
// Set the creation class name of the listener

cimListener.updateProperty(new CIMProperty("CreationClassName",
                       new CIMValue("CIM_ListenerDestinationCIMXML",
                       CIMDataType.getPredefinedType(CIMDataType.STRING))));

// Set the system creation class name of the listener

cimListener.updateProperty(new CIMProperty("SystemCreationClassName",
                       new CIMValue(null, 
                       CIMDataType.getPredefinedType(CIMDataType.STRING))));

// Set the system name of the listener

cimListener.updateProperty(new CIMProperty("SystemName",
                       new CIMValue(null, 
                       CIMDataType.getPredefinedType(CIMDataType.STRING))));

// Set the name of the listener

cimListener.updateProperty(new CIMProperty("Name",
                       new CIMValue(listenerName, 
                       CIMDataType.getPredefinedType(CIMDataType.STRING))));

// Set destination value, it should be combined with IP address of client and
// hash code of the listener object

cimListener.updateProperty(new CIMProperty("Destination", 
                           new CIMValue(IPAddress +
                                         "/" +
                                         internalListener.hashCode(),
                      CIMDataType.getPredefinedType(CIMDataType.STRING))));

// Register the listener destination on the target CIM server

CIMObjectPath listenerCOP = _client.createInstance(new CIMObjectPath(),
                                                    cimListener);

// Define class name of indication subscription

String subscriptionClassName = "CIM_IndicationSubscription";

// Construct object path of CIM_IndicationSubscription 

CIMObjectPath cop = new CIMObjectPath(subscriptionClassName, _namespace);

// Get the  CIMClass object for subscription

CIMClass subscriptionClass = _client.getClass(cop);

// Create CIM_IndicationSubscription instance and set properties

CIMInstance subscriptionInstance = subscriptionClass.newInstance();

// Set object path of event filter instance as the value of "Filter" property

subscriptionInstance.setProperty("Filter",
                                new CIMValue(filterInstance.getObjectPath(), 
                                new CIMDataType(CIMDataType.REFERENCE)));

// Set object path of event handler instance as the value of "Handler" property

subscriptionInstance.setProperty("Handler",
                               new CIMValue(handlerInstance.getObjectPath(), 
                               new CIMDataType(CIMDataType.REFERENCE)));

// Create CIM_IndicationSubscription instance on the target CIM server

CIMObjectPath sop = _client.createInstance(new CIMObjectPath(),
                                          subscriptionInstance);