x/stacktach-notigen
Code Issues Proposed changes

now writes events to notabene

Browse Source
This commit is contained in:
Sandy Walsh 2014-05-21 18:34:04 +00:00
parent 0768b3865a
commit 5c3f12f761
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
bin/event_pump.py
View File

@ -17,6 +17,9 @@ import notigen
connection = driver.create_connection("localhost", 5672, 'guest', 'guest',
"librabbitmq", "/")
exchange = driver.create_exchange("monitor", "topic")
queue_name = "monitor.info"
queue = driver.create_queue(queue_name, exchange, queue_name, channel=connection.channel())
queue.declare()
g = notigen.EventGenerator(100) # Number of operations per minute
now = datetime.datetime.utcnow()
@ -27,6 +30,7 @@ while nevents < 10000:
if e:
nevents += len(e)
for event in e:
driver.send_notification(event, "monitor.info", connection, exchange)
driver.send_notification(event, queue_name, connection, exchange)
print nevents, event['when'], event['event']
now = datetime.datetime.utcnow()