def METHOD_NAME(self) -> None:
    output = []
    queue_client = get_queue_client()
    def collect(events: List[Dict[str, Any]]) -> None:
        assert isinstance(queue_client, SimpleQueueClient)
        assert len(events) == 1
        output.append(events[0])
        queue_client.stop_consuming()
    queue_json_publish("test_suite", {"event": "my_event"})
    queue_client.start_json_consumer("test_suite", collect)
    self.assert_length(output, 1)
    self.assertEqual(output[0]["event"], "my_event")