Transaction

gistfile1.txt

			try {
				$connection->beginTransaction();
				$connection->exec($insertQuery, $insertValues);

				if ($lastProspectId) {
					$listEmail->setClientType($lastProspectId);
					$listEmail->save($connection);
				}

				$connection->commit();
				$queuedSuccessfully = true;

			} catch (Exception $e) {
				$connection->rollback();
				if (EmailManager::exceptionIndicatesDeadlock($e)) {
					//retry on deadlock
					$queueException = $e;

				} else {
					//non-deadlock, bail out immediately w/o retrying
					GraphiteClient::increment('email.failure.queue.nodeadlock');
					...
					throw $e;
				}
				...
			}