geowatchutil.broker.base module

Contains the base GeoWatchBroker class

class geowatchutil.broker.base.GeoWatchBroker(name, description, consumers=None, producers=None, duplex=None, stores_in=None, stores_out=None, count=1, timeout=5, threads=1, sleep_period=5, deduplicate=False, filter_metadata=None, filter_last_one=False, verbose=False)

Bases: object

Base broker class. This class can pass messages among consumers, producers, and stores. If you wish to add more advanced logic, extend the class and overwrite the _pre and _post functions.

close()

consumers = None

count = 1

cycle_in_consumer(consumer, messages_all)

deduplicate = False

delete_topics()

Deletes all topics attached to consumers and producers. Useful for cleaning up after testing.

description = None

duplex = None

filter_last_one = False

filter_metadata = None

name = None

producers = None

receive_message(message=None, filter_messages=True)

receive_messages(messages=None, filter_messages=True)

run(max_cycle=0, run_cycle_out=True)

sleep_period = None

stores_in = None

stores_out = None

threads = None

timeout = 5

verbose = False