Processor.php

<?php
/**
 * Copyright © Magento, Inc. All rights reserved.
 * See COPYING.txt for license details.
 */
namespace Magento\MysqlMq\Model;

/**
 * Test message processor is used by \Magento\MysqlMq\Model\PublisherTest
 */
class Processor
{
    /**
     * @param \Magento\MysqlMq\Model\DataObject $message
     */
    public function processMessage($message)
    {
        echo "Processed {$message->getEntityId()}\n";
    }

    /**
     * @param \Magento\MysqlMq\Model\DataObject $message
     */
    public function processMessageWithException($message)
    {
        throw new \LogicException("Exception during message processing happened. Entity: {{$message->getEntityId()}}");
    }
}