public function save()
    {
        try
        {
            $connection = new Connection($this->buildConnectionOptions());
            $connection->open();

            $msg = new AMQPMessage($this->message, array('content_type' => $this->content_type, 'delivery_mode' => 2));
            $connection->channel->basic_publish($msg, $this->exchange, $this->queue_name);

            $connection->close();
        }
        catch (Exception $e)
        {
            $connection->close();
            throw new Exception($e);
        }
    }