def following_messages_are_sent_to_secondary_consumer(context):

    for element in context.table.rows:
        expected_message = dict(element.as_dict())
        expected_message = _dataset_utils.prepare_data(expected_message)

        assert_that(expected_message, is_message_in_consumer_list(context.secondaty_rabbitmq_consumer.message_list),
                    "A message with the expected content has not been received by the secondary RabbitMQ consumer")