def METHOD_NAME(*args, **kwargs):
    # We want to just exit after the callback so that we can see the result of
    # processing.
    original_callback(*args, **kwargs)
    consumer.signal_shutdown()