diff options
| author | horus_arch | 2017-02-20 12:42:43 +0100 |
|---|---|---|
| committer | horus_arch | 2017-02-20 12:42:43 +0100 |
| commit | 95c15758b50144105064d2613d1e9a9da23d4e7c (patch) | |
| tree | 373eea2812fa4a7c6f58c16528e2875a208b1ada /intern.gospeladlershof.de/vendor/pda/pheanstalk/src/Command/UseCommand.php | |
| parent | 3702922f4ab7f3d73f802b94d8b36571c589cb2c (diff) | |
| download | gospeladlershof.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.php | 52 |
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) + )); + } +} |
