event_queue

class pyogp.lib.base.event_queue.EventQueueClient(capability=None, settings=None, packet_handler=None, region=None, event_queue_handler=None)

handles an event queue of either an agent domain or a simulator

Initialize the event queue client class >>> client = EventQueueClient()

The event queue client requires an event queue capability >>> from pyogp.lib.base.caps import Capability >>> cap = Capability(‘EventQueue’, http://localhost:12345/cap)

>>> event_queue = EventQueueClient(cap)
>>> event_queue.start()

Sample implementations: region.py Tests: tests/test_event_queue.py

set up the event queue attributes

start()

stop()

class pyogp.lib.base.event_queue.EventQueueHandler(settings=None)

general class handling individual packets

i do nothing

is_packet_handled(name)

if the data is being monitored, return True, otherwise, return False

this can allow us to skip parsing inbound packets if no one is watching a particular one

class pyogp.lib.base.event_queue.EventQueueReceivedNotifier(name, settings)

received TestMessage packet

received(data)

subscribe(*args, **kwdargs)

unsubscribe(*args, **kwdargs)