florianajir / rabbitmq-sql-worker

     * @param AMQPMessageInterface $message

     * @param InvalidArgumentException $exception

     */

    private function logMessageInvalid(AMQPMessageInterface $message, InvalidArgumentException $exception)

    {

        if (null !== $this->logger) {

            $this->logger->warning(

                'Message invalid',

                array(

                    'type' => $message->getType(),

                    'data' => $message->getData(),

                    'exception' => $exception

                )

            );

        }

    }

    /**

     * @param AMQPMessageInterface $message

     * @param AMQPMessageInterface $message

     * @param Exception $exception

     */

    private function logMessageError(AMQPMessageInterface $message, Exception $exception)

    {

        if (null !== $this->logger) {

            $this->logger->error(

                'Consumer SQL Exception',

                array(

                    'type' => $message->getType(),

                    'data' => $message->getData(),

                    'exception' => $exception

                )

            );

        }

    }

}