summaryrefslogtreecommitdiff
path: root/intern.gospeladlershof.de/vendor/pda/pheanstalk/src/Command/UseCommand.php
diff options
context:
space:
mode:
authorhorus_arch2017-02-20 12:42:43 +0100
committerhorus_arch2017-02-20 12:42:43 +0100
commit95c15758b50144105064d2613d1e9a9da23d4e7c (patch)
tree373eea2812fa4a7c6f58c16528e2875a208b1ada /intern.gospeladlershof.de/vendor/pda/pheanstalk/src/Command/UseCommand.php
parent3702922f4ab7f3d73f802b94d8b36571c589cb2c (diff)
downloadgospeladlershof.de-95c15758b50144105064d2613d1e9a9da23d4e7c.tar.gz
Committed vendor/ for lazyness.
Diffstat (limited to 'intern.gospeladlershof.de/vendor/pda/pheanstalk/src/Command/UseCommand.php')
-rw-r--r--intern.gospeladlershof.de/vendor/pda/pheanstalk/src/Command/UseCommand.php52
1 files changed, 52 insertions, 0 deletions
diff --git a/intern.gospeladlershof.de/vendor/pda/pheanstalk/src/Command/UseCommand.php b/intern.gospeladlershof.de/vendor/pda/pheanstalk/src/Command/UseCommand.php
new file mode 100644
index 0000000..5e5ba70
--- /dev/null
+++ b/intern.gospeladlershof.de/vendor/pda/pheanstalk/src/Command/UseCommand.php
@@ -0,0 +1,52 @@
+<?php
+
+namespace Pheanstalk\Command;
+
+use Pheanstalk\ResponseParser;
+
+/**
+ * The 'use' command.
+ *
+ * The "use" command is for producers. Subsequent put commands will put jobs into
+ * the tube specified by this command. If no use command has been issued, jobs
+ * will be put into the tube named "default".
+ *
+ * @author Paul Annesley
+ * @package Pheanstalk
+ * @license http://www.opensource.org/licenses/mit-license.php
+ */
+class UseCommand
+ extends AbstractCommand
+ implements \Pheanstalk\ResponseParser
+{
+ /**
+ * @var string
+ */
+ private $_tube;
+
+ /**
+ * @param string $tube The name of the tube to use
+ */
+ public function __construct($tube)
+ {
+ $this->_tube = $tube;
+ }
+
+ /* (non-phpdoc)
+ * @see Command::getCommandLine()
+ */
+ public function getCommandLine()
+ {
+ return 'use '.$this->_tube;
+ }
+
+ /* (non-phpdoc)
+ * @see ResponseParser::parseResponse()
+ */
+ public function parseResponse($responseLine, $responseData)
+ {
+ return $this->_createResponse('USING', array(
+ 'tube' => preg_replace('#^USING (.+)$#', '$1', $responseLine)
+ ));
+ }
+}