def METHOD_NAME(self, opts):
    self.queue_tablename = opts.get('queue_tablename', 'kombu_queue')
    self.message_tablename = opts.get('message_tablename', 'kombu_message')
    #
    # Define the model definitions.  This registers the declarative
    # classes with the active SQLAlchemy metadata object.  This *must* be
    # done prior to the ``create_engine`` call.
    #
    self.queue_cls and self.message_cls