Exception on affected record !=1.

additional exception; avoid using Type::BOOLEAN.

Author: otzy

pkg/dbal/DbalProducer.php

@@ -115,7 +115,7 @@ public function send(Destination $destination, Message $message): void
         }
 
         try {
-            $this->context->getDbalConnection()->insert($this->context->getTableName(), $dbalMessage, [
+            $rowsAffected = $this->context->getDbalConnection()->insert($this->context->getTableName(), $dbalMessage, [
                 'id' => Type::GUID,
                 'published_at' => Type::INTEGER,
                 'body' => Type::TEXT,
@@ -125,10 +125,14 @@ public function send(Destination $destination, Message $message): void
                 'queue' => Type::STRING,
                 'time_to_live' => Type::INTEGER,
                 'delayed_until' => Type::INTEGER,
-                'redelivered' => Type::BOOLEAN,
+                'redelivered' => Type::SMALLINT,
                 'delivery_id' => Type::STRING,
                 'redeliver_after' => Type::BIGINT,
             ]);
+            
+            if ($rowsAffected !== 1) {
+                throw new Exception('The message was not enqueued. Dbal did not confirm that record inserted.');
+            }
         } catch (\Exception $e) {
             throw new Exception('The transport fails to send the message due to some internal error.', 0, $e);
         }