def METHOD_NAME(self, Handler):
    msg = Message(
        topic="org.fedoraproject.prod.resultsdb.result.new",
        body={}
    )
    handler = mock.Mock()
    Handler.side_effect = lambda: handler
    Consumer()(msg)
    handler.assert_called_once_with(msg)