The following code is a snipet taken from an example of pheanstalk being implemented and working properly (obtained from pheanstalk's github page: https://github.com/pda/pheanstalk):
<?php
require_once("vendor/autoload.php");
use Pheanstalk\Pheanstalk;
$pheanstalk = new Pheanstalk('127.0.0.1');
// ------------ producer (queues jobs):
$pheanstalk
->useTube('testtube')
->put("job payload goes here\n");
// ------------ worker (performs jobs):
$job = $pheanstalk
->watch('testtube')
->ignore('default')
->reserve();
echo $job->getData();
$pheanstalk->delete($job);
// ------------ check server availability
$pheanstalk->getConnection()->isServiceListening(); // true or false
QUESTIONS:
What I don't understand are the following parts:
I am assuming that the newline spaces in the
producer
code don't make any difference in the execution, so this line would be equivalent:$pheanstalk->useTube('testtube')->put("job payload goes here\n");
correct? If that is true, then do those specific function calls have to be in that order, or can they be in any order? My previous understanding of functions and classes in php was that you would directly call a function from an object of it's class type: $object->classFunction()
, however is the above code a valid php technique where you can call all those functions simultaneously or is it something special to pheanstalk?
What is the
ignore('default')
code doing?What is the
$pheanstalk->getConnection()->isServiceListening();
code doing?
is equivalent to:
So first it calls
useTube()
to specify which tube the payload should be put into, then it puts the payload into that. It's depending on the fact that methods that perform actions return thePheanstalk
object they were called on, so it's also short for:ignore(tubename)
removes that tube from the watchlist. Thedefault
tube is watched by default, so this disables that and just waits for messages in thetesttube
tube.It's doing exactly what the comment above it says: Checking that the server is available. You could use this in your producer code to report an error before trying to send to a beanstalk server that's not listening.