from .db_consumer import DbConsumer


class DbRunner():
    @staticmethod
    def run(host, port):
        DbConsumer(host, port).start_consuming()
94787b99c82e85787a64e9662a15d44a8216102c
<mask token>

<mask token>


class DbRunner:
    <mask token>

<mask token>


class DbRunner:

    @staticmethod
    def run(host, port):
        DbConsumer(host, port).start_consuming()

from .db_consumer import DbConsumer


class DbRunner:

    @staticmethod
    def run(host, port):
        DbConsumer(host, port).start_consuming()

from .db_consumer import DbConsumer


class DbRunner():
    @staticmethod
    def run(host, port):
        DbConsumer(host, port).start_consuming()