xobotyi / beansclient Goto Github PK

<?php
if (PHP_SAPI !== 'cli') die('NO');
require __DIR__ . '/vendor/autoload.php';
use xobotyi\beansclient\BeansClient;
use xobotyi\beansclient\Connection;

$str = "a";
for ($i=0;$i<15280;$i++) {
    $str.='a'; //lets build a really long string
}

$connection = new Connection('10.15.21.49', '11300', 2, false);
$beansClient = new BeansClient($connection);

$loop = 0;
$s = $beansClient->stats();

print_r($s);

while ($loop < 1500 ) {
    $loop++;
    $str .= 'a'; //slowly increase the size of the string
    echo strlen($str);
    echo "\n";
    echo "Putting job\n";
    $beansClient->useTube('default')->put($str);
    echo "Getting job\n";
    $job = $beansClient->watchTube('default')->reserve();
    $id = $job->id;
    if (empty($id)) echo "No jobs...and timedout\n";
    else echo "Job is is " . $id . "\n";
    if ($id) {
        echo "\n";
        $len = strlen($job->payload);
        echo "\n";
        echo $len;
        echo "\n";
        $beansClient->delete($id);
    } else {
        die('ooops');
    }
}

use xobotyi\beansclient\Serializer\Json;
$client = new BeansClient(new Connection(), new Json());

use xobotyi\beansclient\Serializer\JsonSerializer;
$client = new BeansClient(new Connection(), new JsonSerializer());

PHP Fatal error:  Uncaught xobotyi\beansclient\Exception\Command: Got unexpected status code [DEADLINE_SOON] in /home/Serve/Resque/vendor/xobotyi/beansclient/src/Command/Reserve.php:65
Stack trace:
#0 /home/Serve/Resque/vendor/xobotyi/beansclient/src/BeansClient.php(122): xobotyi\beansclient\Command\Reserve->parseResponse(Array, NULL)
#1 /home/Serve/Resque/vendor/xobotyi/beansclient/src/BeansClient.php(304): xobotyi\beansclient\BeansClient->dispatchCommand(Object(xobotyi\beansclient\Command\Reserve))
#2 /home/Serve/Resque/lib/src/Resque/Serve.php(46): xobotyi\beansclient\BeansClient->reserve()
#3 {main}
  thrown in /home/Serve/Resque/vendor/xobotyi/beansclient/src/Command/Reserve.php on line 65

while (true) {
    try {
        $job = $beansClient->watchTube('Order')
            ->reserve();
        $payload = $job->payload;
        if (!empty($payload))
        {
            var_dump($job->payload);
        }
    } catch (\Exception $ex) {
        var_dump($ex->getTraceAsString());
        var_dump($beansClient->getConnection()->isActive());
        exit;
    }
}

string(406) "#0 /home/Serve/Resque/vendor/xobotyi/beansclient/src/BeansClient.php(122): xobotyi\beansclient\Command\Reserve->parseResponse(Array, NULL)
#1 /home/Serve/Resque/vendor/xobotyi/beansclient/src/BeansClient.php(304): xobotyi\beansclient\BeansClient->dispatchCommand(Object(xobotyi\beansclient\Command\Reserve))
#2 /home/Serve/Resque/app/test/stalk.php(24): xobotyi\beansclient\BeansClient->reserve()
#3 {main}"
bool(true)

PHP Fatal error:  Uncaught xobotyi\beansclient\Exception\SocketException: Host `/tmp/beanstalkd.sock` not exists or unreachable in /beans/vendor/xobotyi/beansclient/src/Socket/SocketSocket.php:32
Stack trace:
#0 /beans/vendor/xobotyi/beansclient/src/Socket/SocketFactory.php(120): xobotyi\beansclient\Socket\SocketSocket->__construct('/tmp/beanstalkd...', -1, 2)
#1 /beans/vendor/xobotyi/beansclient/src/Connection.php(34): xobotyi\beansclient\Socket\SocketFactory->createSocket()
#2 /beans/writer.php(9): xobotyi\beansclient\Connection->__construct('/tmp/beanstalkd...', -1)
------
root@box:~/beans$ ls -l  /tmp/beanstalkd.sock
srwxr-xr-x 1 root root 0 Mar 27 06:21 /tmp/beanstalkd.sock

$client = new BeansClient(new Connection());
$client->watchTube('Project.Orders');
$job = $client->reserve(30);

// Exception: Unknown error in [/xobotyi/beansclient/src/Socket/SocketBase.php, line 158]
Stack Trace:
#0 /vendor/xobotyi/beansclient/src/Socket/SocketBase.php(175): xobotyi\beansclient\Socket\SocketBase->throwLastError()
#1 /vendor/xobotyi/beansclient/src/Connection.php(120): xobotyi\beansclient\Socket\SocketBase->readLine()
#2 /vendor/xobotyi/beansclient/src/BeansClient.php(76): xobotyi\beansclient\Connection->readLine()
#3 /vendor/xobotyi/beansclient/src/BeansClient.php(317): xobotyi\beansclient\BeansClient->dispatchCommand(Object(xobotyi\beansclient\Command\Reserve))
#4 /src/Command/OrdersCommand.php(30): xobotyi\beansclient\BeansClient->reserve(30)
[...]