For example, Memcache::add() takes arguments (key, data, expiry), but Base::add() and IronMQ::add() start with the $data argument. It seems like the right thing to do is change the signature in Memcache::add to start with $data.

Hello,

I've tested your script but seems that once you run php SimpleRunner.php all jobs added after that are not updated.

I've tried also to run BeanstalkSampleDaemon but there are several errors like:

Fatal error: Class 'Pheanstalk\Pheanstalk' not found

No changes needed to the Logger class itself, as the StreamHandler constructor is compatible in 2.x. Usages of non-PSR-standard e.g. Logger->addInfo() methods are replaced with PSR-standard e.g. Logger->info() calls, as both exist in 1.x and the former are removed in Monolog 2.

See https://github.com/Seldaek/monolog/blob/main/UPGRADE.md

I noticed Amazon released version 2 of their PHP SDK a while back, so I added support for it.

The changes include:

• Moving Respect/Rest to the "suggest" section in composer.json, since some people may not want to use the REST server, or wish to implement it themselves
• Added the PEAR repository definition, which is required for microsoft/windowsazure
• Bumped the Monolog version for compatibility with newer Symfony2 libraries (the new AWS SDK depends on the Symfony2 event dispatcher and Guzzle)
• Added AmazonSQSV2 and AmazonS3V2 Backend classes, which use the new library functions
• Added Base::setConnection(), which enables dependency injection (e.g. someone might want to pass an existing connection object to a backend instance)
• Added tests for the new classes and functions

What do you think? I thought of simply replacing the AWS classes, but some people might want to stay with the old SDK. Maybe do it in a different version branch?

Hey, excellent project and all, but you should be aware of the existence of this tool:

https://bitbucket.org/idler/mmp/wiki/Home

how about incorporating the two!

Edit: the project page is now at

https://github.com/idler/MMP/

Hi,

Is there any possibility to delay a queued job ?

for example this job must be delayed 5 minutes.

 $obj = array(
                'Schedule' => time() + (5 * 60)
            );
$queue->addJob($obj);

If you have other idea will be great. Thanks.

There is some tension between the queue backend functions which return true and throw exceptions. If there is no way to return false, then calling code will include redundant error handling for no good reason.

However, voiding the return value will probably break existing code. We can leave the "return true" until this usage is deprecated...

Do you agree that we should throw a JobNotFound exception whenever get($key) or pop() fails to find a message?

This is an automated request to remove excessive whitespace from source code. You can find more about this project and opt-out at whitespacestrippers.com

php-queue\src\PHPQueue\Base.php Line 48 - if (file_exists($classFile)) Line 175 - if (file_exists($classFile))

php-queue\src\PHPQueue\Backend\CSV.php Line 29 - if ( !file_exists($this->file_path) )

• Removes our non-queuey KeyValueStore and IndexedFifoQueueStore interfaces These were only supported by certain backends, and support in those was buggy (i.e. delete in ActiveMQ only works if the key is within a certain distance of the top)
• Adds an AtomicReadBuffer interface Useful for at-least-once processing. Gets a value from the queue and only pops it off once a callback has completed successfully
• Bugfixes for Predis and PDO backends

Please let me know if you'd like me to break up this PR!

Hi,

First of all thanks to author and contributors for this useful script.

I enjoyed it a lot but I also wanted to have a delay feature so i decided to contribute a little to this awesome script adding this feature.

    DEFAULT_PRIORITY = 1024; // most urgent: 0, least urgent: 4294967295
    DEFAULT_DELAY = 0; // no delay
    DEFAULT_TTR = 60; // 1 minute

Example of using:

$queue = new MyQueue();
$test = array('test'=>'test2');
$queue->addJob($test, 1024, 60, 60);

Hello!

Please look at https://github.com/queue-interop/queue-interop project. Using interfaces from it allows us reuse some implementations like enqueue, which supports a lot of transports. You can outsource some code

Hey, so I have structure like this

PHPQueue\Base::$queue_namespace = 'App\Queue\Queues'; PHPQueue\Base::$worker_namespace = 'App\Queue\Workers';

├── Queues │   ├── SampleQueue.php │   └── logs │   └── results.log ├── Runners │   └── SampleRunner.php └── Workers └── SampleWorker.php

when running trought CLI

Adding Job... Fatal error: Class 'App\Queue\Queues\Sample' not found in ...

So :QueueNameInCamelCase:Queue.php is not working for namespaces

  Problem 1
    - Installation request for microsoft/windowsazure dev-master -> satisfiable by microsoft/windowsazure[dev-master].
    - microsoft/windowsazure dev-master requires pear-pear2.php.net/http_request2 * -> no matching package found.

Hi,

I have been really busy with my career these few years. Haven't been doing a good job of keeping this library up to date.

I'm hoping to open up commit access to other developers who might want to help take this project further. Do respond here to email me at [email protected] to discuss further.

Thanks!

Interfaces\Config is unused. Tests and demo applications should be locally configured with a single file config.yaml.example, rather than in code.

I don't know what the config data should look like. It would be nice to include backend dependency injection, as well as defaults for each backend, but this seems like an overly complicated configuration file, it would look something like:

stomp:
    uri: tcp://host.localhost.net:61613
    read_timeout: 10

queues:
    test_stomp:
        backend: Stomp

I like the idea of keeping before & after hooks on every action in the Base class, but what do you think about decoupling the job tracking (last_job_id and open_items) into a new class? Or even isolating all job queue logic in a new component? Plain old queue stuff is a useful service to provide in a library, on its own!

Also, I don't understand how the before and after hooks would be overridden. Maybe there should be an example in the demo/ dir? I ask because I'm thinking about removing or refactoring these functions, if they aren't being used.