From 95c15758b50144105064d2613d1e9a9da23d4e7c Mon Sep 17 00:00:00 2001
From: horus_arch
Date: Mon, 20 Feb 2017 12:42:43 +0100
Subject: Committed vendor/ for lazyness.

---
 .../pda/pheanstalk/src/Command/BuryCommand.php     | 62 ++++++++++++++++++++++
 1 file changed, 62 insertions(+)
 create mode 100644 intern.gospeladlershof.de/vendor/pda/pheanstalk/src/Command/BuryCommand.php

(limited to 'intern.gospeladlershof.de/vendor/pda/pheanstalk/src/Command/BuryCommand.php')

diff --git a/intern.gospeladlershof.de/vendor/pda/pheanstalk/src/Command/BuryCommand.php b/intern.gospeladlershof.de/vendor/pda/pheanstalk/src/Command/BuryCommand.php
new file mode 100644
index 0000000..d16a4bb
--- /dev/null
+++ b/intern.gospeladlershof.de/vendor/pda/pheanstalk/src/Command/BuryCommand.php
@@ -0,0 +1,62 @@
+<?php
+
+namespace Pheanstalk\Command;
+
+use Pheanstalk\Exception;
+use Pheanstalk\Response;
+
+/**
+ * The 'bury' command.
+ * Puts a job into a 'buried' state, revived only by 'kick' command.
+ *
+ * @author Paul Annesley
+ * @package Pheanstalk
+ * @license http://www.opensource.org/licenses/mit-license.php
+ */
+class BuryCommand
+    extends AbstractCommand
+    implements \Pheanstalk\ResponseParser
+{
+    private $_job;
+    private $_priority;
+
+    /**
+     * @param object $job      Job
+     * @param int    $priority From 0 (most urgent) to 0xFFFFFFFF (least urgent)
+     */
+    public function __construct($job, $priority)
+    {
+        $this->_job = $job;
+        $this->_priority = $priority;
+    }
+
+    /* (non-phpdoc)
+     * @see Command::getCommandLine()
+     */
+    public function getCommandLine()
+    {
+        return sprintf(
+            'bury %u %u',
+            $this->_job->getId(),
+            $this->_priority
+        );
+    }
+
+    /* (non-phpdoc)
+     * @see ResponseParser::parseResponse()
+     */
+    public function parseResponse($responseLine, $responseData)
+    {
+        if ($responseLine == Response::RESPONSE_NOT_FOUND) {
+            throw new Exception\ServerException(sprintf(
+                '%s: Job %u is not reserved or does not exist.',
+                $responseLine,
+                $this->_job->getId()
+            ));
+        } elseif ($responseLine == Response::RESPONSE_BURIED) {
+            return $this->_createResponse(Response::RESPONSE_BURIED);
+        } else {
+            throw new Exception('Unhandled response: '.$responseLine);
+        }
+    }
+}
-- 
cgit v1.2.3