Commit 21e8732b authored by Tim Schoof's avatar Tim Schoof
Browse files

Remove default consumer class

parent 674507fc
......@@ -6,14 +6,13 @@ from AsapoWorker.configuration import (
create_instance_from_configurable,
create_cli_parser_from_configurable_class,
parsed_args_to_dict)
from AsapoWorker.asapo_receiver import AsapoReceiver
from AsapoWorker.streamer import Streamer
from AsapoWorker.errors import StreamError
class Application:
def __init__(
self, worker_class, consumer_class=AsapoReceiver,
self, worker_class, consumer_class,
producer_class=None,
verbose=False, log_level=logging.WARN):
self.worker_class = worker_class
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment