1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
import logging
import time
from threading import Semaphore
from qpid.messaging import *
from qmfCommon import (AgentId, SchemaEventClassFactory, qmfTypes, SchemaProperty,
SchemaObjectClass, ObjectIdFactory, QmfData, QmfDescribed,
QmfDescribedFactory, QmfManaged, QmfManagedFactory, QmfDataFactory,
QmfEvent, SchemaMethod, Notifier)
from qmfAgent import (Agent, QmfAgentData)
class ExampleNotifier(Notifier):
def __init__(self):
self._sema4 = Semaphore(0) # locked
def indication(self):
self._sema4.release()
def waitForWork(self):
logging.error("Waiting for event...")
self._sema4.acquire()
logging.error("...event present")
#
# An example agent application
#
_notifier = ExampleNotifier()
_agent = Agent( "redhat.com", "qmf", "testAgent", _notifier )
# Dynamically construct a class schema
_schema = SchemaObjectClass( "MyPackage", "MyClass",
desc="A test data schema",
_pkey=["index1", "index2"] )
# add properties
_schema.addProperty( "index1",
SchemaProperty(qmfTypes.TYPE_UINT8))
_schema.addProperty( "index2",
SchemaProperty(qmfTypes.TYPE_LSTR))
# these two properties are statistics
_schema.addProperty( "query_count",
SchemaProperty(qmfTypes.TYPE_UINT32))
_schema.addProperty( "method_call_count",
SchemaProperty(qmfTypes.TYPE_UINT32))
# These two properties can be set via the method call
_schema.addProperty( "set_string",
SchemaProperty(qmfTypes.TYPE_LSTR))
_schema.addProperty( "set_int",
SchemaProperty(qmfTypes.TYPE_UINT32))
# add method
_meth = SchemaMethod( _desc="Method to set string and int in object." )
_meth.addArgument( "arg_int", SchemaProperty(qmfTypes.TYPE_UINT32) )
_meth.addArgument( "arg_str", SchemaProperty(qmfTypes.TYPE_LSTR) )
_schema.addMethod( "set_meth", _meth )
# Add schema to Agent
_agent.registerObjectClass(_schema)
# instantiate managed data objects matching the schema
_obj = QmfAgentData( _agent, _schema )
_obj.setProperty("index1", 100)
_obj.setProperty("index2", "a name" )
_obj.setProperty("set_string", "UNSET")
_obj.setProperty("set_int", 0)
_obj.setProperty("query_count", 0)
_obj.setProperty("method_call_count", 0)
_agent.addObject( _obj )
_agent.addObject( QmfAgentData( _agent, _schema,
_props={"index1":99,
"index2": "another name",
"set_string": "UNSET",
"set_int": 0,
"query_count": 0,
"method_call_count": 0} ))
## Now connect to the broker
_c = Connection("localhost")
_c.connect()
_agent.setConnection(_c)
_done = False
while not _done:
try:
_notifier.waitForWork()
_wi = _agent.getNextWorkItem(timeout=0)
while _wi:
print("work item %d:%s" % (_wi.getType(), str(_wi.getParams())))
_agent.releaseWorkItem(_wi)
_wi = _agent.getNextWorkitem(timeout=0)
except:
logging.info( "shutting down..." )
_done = True
logging.info( "Removing connection... TBD!!!" )
#_myConsole.remove_connection( _c, 10 )
logging.info( "Destroying agent... TBD!!!" )
#_myConsole.destroy( 10 )
logging.info( "******** agent test done ********" )
|
