# Path: carrot/objects.py
# class DefaultMessageSerializer(BaseMessageSerializer):
#     type_header = 'type'
#     message_type = 'django-carrot message'


from carrot.objects import DefaultMessageSerializer

class IoLoop(object):
    def stop(self):
        pass

    def start(self):
        pass


class Channel(object):
    def __init__(self, *args, **kwargs):
        pass

    def basic_qos(*args, **kwargs):
        return

    def queue_purge(self, queue=''):
        return

    def add_on_close_callback(self):
        return

    @staticmethod
    def close(*args, **kwargs):
        return

    def exchange_declare(self, callback, exchange=None, **kwargs):
        return

    def basic_publish(self, **kwargs):

# Path: carrot/objects.py
# class DefaultMessageSerializer(BaseMessageSerializer):
#     type_header = 'type'
#     message_type = 'django-carrot message'


# Path: carrot/mocks.py
from carrot.objects import DefaultMessageSerializer


class IoLoop(object):
    def stop(self):
        pass

    def start(self):
        pass


class Channel(object):
    def __init__(self, *args, **kwargs):
        pass

    def basic_qos(*args, **kwargs):
        return

    def queue_purge(self, queue=''):
        return

    def add_on_close_callback(self):
        return

    @staticmethod
    def close(*args, **kwargs):
        return

    def exchange_declare(self, callback, exchange=None, **kwargs):
        return

    def basic_publish(self, **kwargs):

        return